C++ 11:除非发布者睡眠,否则发布者/用户模式不会完成。

在C++中,我试图使用Apple获得发布者/用户模式的句柄。 condition_variable . 这是我在网上看到的模板:

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

using namespace std;

mutex m;
queue<string> que;
condition_variable cond;

void write(string &&msg) {
    unique_lock<mutex> locker(m);
    que.push(msg);
    locker.unlock();
    cond.notify_one();
    this_thread::sleep_for(chrono::milliseconds(1));
}

void read() {
    while (true) {
        unique_lock<mutex> locker(m);
        cond.wait(locker);
        if (!que.empty()) {
            cout << que.front() << endl;
            que.pop();
        }
        locker.unlock();
    }
}

void publisher(string &msg) {
    for (int i = 0; i < 100; ++i)
        write("Publisher: " + msg + ", " + to_string(i));
}

int main() {

    string msg = "Hello";
    thread pub_thread(publisher, std::ref(msg));

    /* The main thread will print the publisher's messages to cout. */
    read();

    /* Make the main thread wait for the publisher to finish. */
    pub_thread.join(); //
    return 0;
}

我不明白的是 sleep_for 调用发布者线程。我知道这只是为了模拟一个“真实生活”的场景,在这个场景中,出版商不会这么快地吐出消息。然而,奇怪的是,如果我注释掉那一行,代码就不会运行到完成。为什么会这样?

此外,我尝试将sleep_for time设置为0,效果相同。看来,出版根本上需要睡眠,但我不明白为什么。为了更具体,代码应该打印出100条消息。如果我让代码休眠1毫秒,那么将打印所有100条消息。如果我没有,那么在代码冻结之前我只能看到大约10条消息。似乎出现了僵局。

如果有一个更好的模式可以避免让出版商陷入睡眠状态,那么就可以获得额外的积分…

我知道在实践中,你需要有一个阻止主线的策略,就像毒丸。我故意忽略了这一点,以集中讨论目前的问题。

编辑

嗯。如果我设置了一个块来处理虚假的唤醒,那么这就解决了问题。但这仍然不能解释原始代码失败的原因。

下面是一个改进的读取函数:

void read() {
    while (true) {
        unique_lock<mutex> locker(m);
        cond.wait(locker, [&](){ return !que.empty(); });
        cout << que.front() << endl;
        que.pop();
        locker.unlock();
    }
}