c++ - 理解使用 std::condition_variable 的例子

有一个使用 condition_variable 取自 cppreference.com 的例子:

#include <condition_variable>
#include <mutex>
#include <thread>
#include <iostream>
#include <queue>
#include <chrono>

int main()
{
    std::queue<int> produced_nums;
    std::mutex m;
    std::condition_variable cond_var;
    bool done = false;
    bool notified = false;

    std::thread producer([&]() {
        for (int i = 0; i < 5; ++i) {
            std::this_thread::sleep_for(std::chrono::seconds(1));
            std::lock_guard<std::mutex> lock(m);
            std::cout << "producing " << i << '\n';
            produced_nums.push(i);
            notified = true;
            cond_var.notify_one();
        }

        std::lock_guard<std::mutex> lock(m);
        notified = true;
        done = true;
        cond_var.notify_one();
    });

    std::thread consumer([&]() {
        while (!done) {
            std::unique_lock<std::mutex> lock(m);
            while (!notified) {  // loop to avoid spurious wakeups
                cond_var.wait(lock);
            }
            while (!produced_nums.empty()) {
                std::cout << "consuming " << produced_nums.front() << '\n';
                produced_nums.pop();
            }
            notified = false;
        }
    });

    producer.join();
    consumer.join();
}

如果变量 done 在消费者线程启动之前来到 true ，消费者线程将不会收到任何消息。确实，sleep_for(seconds(1)) 几乎避免了这种情况，但是 理论上是否有可能 (或者如果代码中没有 sleep)？

在我看来，正确的版本应该是这样的，以强制运行消费者循环至少一次:

std::thread consumer([&]() {
    std::unique_lock<std::mutex> lock(m);
    do {
        while (!notified || !done) {  // loop to avoid spurious wakeups
            cond_var.wait(lock);
        }

        while (!produced_nums.empty()) {
            std::cout << "consuming " << produced_nums.front() << '\n';
            produced_nums.pop();
        }

        notified = false;
    } while (!done);
});

最佳答案

是的，您是绝对正确的:在设置 done 之前，消费者线程有一种(远程)可能性不会开始运行。此外，在生产者线程中写入 done 和在消费者线程中读取会产生竞争条件，并且行为未定义。你的版本有同样的问题。在每个 函数的 中将互斥量包裹在整个循环中。对不起，没有精力写正确的代码。

关于c++ - 理解使用 std::condition_variable 的例子，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/15733887/