如何使两个线程轮流执行一个线程结束后执行各自的临界区

问题描述 投票:0回答:1

在具有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上有一个与此类似的问题,但是第二个工人不必比第一个工人运行更长的时间。我现在找不到链接到它。预先感谢您的帮助。

c++ multithreading stl
1个回答
0
投票

当一个线程完成时,另一个将等待没有人发送的通知。当只剩下一个线程时,您需要停止使用条件变量或以其他方式通知条件变量。

© www.soinside.com 2019 - 2024. All rights reserved.