在c ++ 11中退出程序之前等待多个线程完成的正确方法

Question

下面的代码示例将有效地允许一次执行一个 1 个线程。保留对线程的引用，然后稍后调用“Thread.join”具有相同的效果。如何让这些线程以这样的方式运行，程序等待线程独立并行继续，然后退出？在我看来，必须使用其他一些内核对象信号机制。 （简而言之，使用 'join' 将主线程绑定到辅助线程不会让其他线程同时运行？）

int main() {
    while (cin) {
        getline(cin, input_line);
        if (input_line.length()>0)
        {
            thread t = thread(SomeLengthyCheck, input_line);
            t.join();
        }
    }
}

Answer 1

您通常使用线程数组，然后在 for 循环中等待所有这些。

您不必关心订单，因为最终，所有订单都应该完成。

根据您的情况，您需要一个线程堆栈/队列，因为您不知道需要等待多少线程。

int main() {
    std::vector<std::thread> threads;
    std::string input_line;
    while (getline(std::cin, input_line)) {
        if (input_line.length()>0) {
            threads.push_back(std::thread(SomeLengthyCheck, input_line));
        }
    }
    for (auto& th : threads) th.join();    
}

---

编辑：@o11c 建议的异常安全版本

class vthreads : std::vector<std::thread> {
    ~vthreads() { for (auto& th : *this ) th.join(); }
};

int main() {
    vthreads threads;
    std::string input_line;
    while (getline(std::cin, input_line)) {
        if (input_line.length()>0) {
            threads.push_back(std::thread(SomeLengthyCheck, input_line));
        }
    }
}

Answer 2

我不是 linux 专家，但我认为线程附加到 main 的进程，所以当任何线程异步操作主线程时，只需 return-ing 在 main 中就会有操作系统。关闭进程并附加所有子线程。

否则我相信当调用函数在封闭{}之后完成时线程将结束

当全局变量发生这种情况时，您可以向主进程发出信号。

我也认为你对加入感到困惑。 Join 强制异步线程（函数）基本上同步运行，方法是停止调用线程，直到要加入的线程完成。