在具有STL线程的现代C ++中,我希望有两个工作线程轮流执行其工作。一次只能工作一个,并且每个人只能转一圈,而另一人只能转一圈。我有这部分工作。增加的约束是,一个线程需要在另一线程结束后继续轮换。但是在我的代码中,第一个工作线程完成后,其余工作线程就死锁了。我不明白为什么,考虑到第一个工作人员所做的最后一件事是解锁并通知条件变量,它应该唤醒了第二个。这是代码:
{
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线程中的并发性,还是我的代码中仅存在逻辑错误。请注意,SO上有一个与此类似的问题,但是第二个工人不必比第一个工人运行更长的时间。我现在找不到链接到它。预先感谢您的帮助。
当一个线程完成时,另一个将等待没有人发送的通知。当只剩下一个线程时,您需要停止使用条件变量或以其他方式通知条件变量。