併發上的boost :: condition_variable :: notify_one（）

Question

我有一個「引擎」異步處理任務和一項任務，我想等到該任務處理。

boost::condition_variable cvWorkDone; 

DoSomeWork() 
{ 
    PostAsyncJob(DoWorkAsync) // is a boost::asio::post 

    boost::mutex::scoped_lock lock(mtxWorkDoneCv); 
    cvWorkDone.wait(lock); 
} 


DoWorkAsync() 
{ 
    // do some work ... 

    cvWorkDone.notify_one(); 
} 

問題是上面的代碼有競爭條件。如果DoWorkAsync()在DoSomeWork()等待之前通知boost::condition_variable？

我看到boost::condition_variable::wait有第二個參數，可以用來實現這樣的事情

bool bWait; 

DoSomeWork() 
{ 
    bWait = true; 
    PostAsyncJob(DoWorkAsync) // boost::asio::post 

    boost::mutex::scoped_lock lock(mtxWorkDoneCv); 
    cvWorkDone.wait(lock, bWait); 
} 


DoWorkAsync() 
{ 
    // do some work ... 
    boost::mutex::scoped_lock lock(mtxWorkDoneCv); 
    cvWorkDone.notify_one();  
    bWait = false; 
} 

一個布爾值，但併發還是有的...我該如何解決？

Answer 1

由於條件變量不維護他們是否已經暗示與否的狀態，你需要保持狀態的任何可能的條件變量單獨信號（在某些情況下，如隊列的原因，發送條件變量的原因可以異步消失）。所以你可能在你的代碼是這樣的：

boost::condition_variable cvWorkDone; 
bool workdone = false; 

DoSomeWork() 
{ 
    PostAsyncJob(DoWorkAsync) // is a boost::asio::post 

    boost::mutex::scoped_lock lock(mtxWorkDoneCv); 
    while (!workdone) { 
     cvWorkDone.wait(lock); 
    } 
} 


DoWorkAsync() 
{ 
    // do some work ... 

    { 
     boost::mutex::scoped_lock lock(mtxWorkDoneCv); 
     workdone = true; 
    } 
    cvWorkDone.notify_one(); 
} 

注意，這也可以避免boost::condition_variable::wait()虛假的回報。從升壓文檔上boost::condition_variable::wait()：

時通過調用通知這個 - > notify_one（）或這個 - > notify_all（），或不合邏輯的線程將解除封鎖。