0

我有这段代码：

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 0\n";
    }
}

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

提前致谢。

4

2 回答 2

1

您正在经历旨在解决 condition_variable 的常见场景“虚假唤醒”（请参阅​​ wiki）。

请阅读本文中的示例代码：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();
}
于 2013-11-05T07:37:36.827 回答
0

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

于 2013-11-05T08:08:17.213 回答