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() 上的 boost 文档：

当调用 this->notify_one() 或 this->notify_all()，或虚假，线程将解除阻塞。