C++11:条件变量只工作一次

C++11: condition variable only works for once

本文关键字：一次 工作 条件 变量 C++11      更新时间：2023-10-16

我有这段代码： 

std::unique_lock<std::mutex> lock(m_mutex);
for(;;)
{
    // wait for input notification
    m_event.wait(lock);
    // if there is an input pin doesn't have any data, just wait
    for(DataPinIn* ptr:m_in_ports)
        if(ptr->m_data_dup==NULL)
            continue;
    // do work
    Work(&m_in_ports,&m_out_ports);
    // this might need a lock, we'll see
    for(DataPinIn* ptr:m_in_ports)
    {
        // reduce the data refcnt before we lose it
        ptr->FreeData();
        ptr->m_data_dup=NULL;
        std::cout<<"ptr:"<<ptr<<"set to 0n";
    }
}

其中m_event是一个condition_variable。它等待来自另一个线程的通知，然后执行一些工作。但我发现这只是第一次成功，并且无论调用 m_event.notify_one（） 多少次，它都会永远阻止 m_event.wait（lock）。我应该如何解决这个问题？

提前谢谢。

您正在经历常见的场景"虚假唤醒"（请参阅wiki），condition_variable注定要解决这种情况。

请阅读本文中的示例代码：http://www.cplusplus.com/reference/condition_variable/condition_variable/。

通常condition_variable必须与某个变量一起使用以避免虚假唤醒;这就是同步方法的命名方式。

下面是一段更好的示例代码：

#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::unique_lock<std::mutex> lock(m);
            std::cout << "producing " << i << 'n';
            produced_nums.push(i);
            notified = true;
            cond_var.notify_one();
        }   
        done = true;
        cond_var.notify_one();
    }); 
    std::thread consumer([&]() {
        std::unique_lock<std::mutex> lock(m);
        while (!done) {
            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();
}

事实证明，标志变量破坏了一切，线程部分正常工作。

相关文章：