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.notify_one()が何度呼び出されても、m_event.wait(lock)で永久にブロックされることがわかりました。これをどのように解決すればよいですか？

前もって感謝します。

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 に答える