在使用STL线程的现代C++中,我希望有两个工作线程轮流执行它们的工作。一次只能有一个人在工作,而且每个人只能在另一个人转一轮之前得到一个回合。我让这部分起作用了。添加的约束是,一个线程需要在另一个线程完成后继续轮流。但在我的代码中,剩余的工作线程在第一个工作线程完成后死锁。我不明白为什么,考虑到第一个worker做的最后一件事是解锁并通知条件变量,这应该会唤醒第二个worker。代码如下:
{
std::mutex mu;
std::condition_variable cv;
int turn = 0;
auto thread_func = [&](int tid, int iters) {
std::unique_lock<std::mutex> lk(mu);
lk.unlock();
for (int i = 0; i < iters; i++) {
lk.lock();
cv.wait(lk, [&] {return turn == tid; });
printf("tid=%d turn=%d i=%d/%d\n", tid, turn, i, iters);
fflush(stdout);
turn = !turn;
lk.unlock();
cv.notify_all();
}
};
auto th0 = std::thread(thread_func, 0, 20);
auto th1 = std::thread(thread_func, 1, 25); // Does more iterations
printf("Made the threads.\n");
fflush(stdout);
th0.join();
th1.join();
printf("Both joined.\n");
fflush(stdout);
}我不知道这是不是我不理解STL线程中的并发,或者我的代码中只有一个逻辑错误。请注意,这里有一个类似于此的问题,但第二个worker不必比第一个运行更长的时间。我现在找不到它的链接。提前感谢您的帮助。
发布于 2020-04-14 10:26:47
当一个线程完成后,另一个线程将等待没有人发送的通知。当只剩下一个线程时,您需要停止使用条件变量,或者以其他方式通知条件变量。
https://stackoverflow.com/questions/61199734
复制相似问题