13

我一直boost::mutex::scoped_lock以这种方式使用:

void ClassName::FunctionName()
{
    {  
     boost::mutex::scoped_lock scopedLock(mutex_);
     //do stuff
      waitBoolean=true;
    }
    while(waitBoolean == true ){
        sleep(1);
    }
    //get on with the thread's activities
}

基本上它设置waitBoolean,而另一个线程通过将waitBoolean设置为false来表示它已完成;

但是,这似乎不起作用,因为其他线程无法锁定 mutex_ !

我假设通过将 scoped_lock 括在括号中,我将终止它的锁定。不是这样吗?在线阅读说它只有在调用析构函数时才放弃互斥锁。当它超出本地范围时,它不会被销毁吗?

信号部分代码:

while(running_){
   boost::mutex::scoped_lock scopedLock(mutex_);
   //Run some function that need to be done...
   if(waitBoolean){
      waitBoolean=false;
   }
}

谢谢!

4

3 回答 3

22

要同步两个线程,请使用条件变量。这是以您想要的方式同步两个线程的最先进的方式:

使用 boost,等待部分类似于:

void BoostSynchronisationPoint::waitSynchronisation()
{
    boost::unique_lock<boost::mutex> lock(_mutex);

    _synchronisationSent = false;
    while(!_synchronisationSent)
    {
        _condition.wait(lock); // unlock and wait
    }
}

通知部分类似于:

void BoostSynchronisationPoint::sendSynchronisation()
{
    {
        boost::lock_guard<boost::mutex> lock(_mutex);
        _synchronisationSent = true;
    }

    _condition.notify_all();
}

_synchronisationSent 的业务是避免虚假唤醒:请参阅维基百科

于 2009-08-10T18:02:32.890 回答
16

scoped_lock 确实应该在作用域结束时释放。但是,当您循环它时,您不会锁定 waitBoolean,这表明您在其他地方也没有正确保护它 - 例如,它被设置为 false,您最终会遇到令人讨厌的竞争条件。

我想说你应该使用 boost::condition_variable 来做这种事情,而不是 sleep + 线程不安全检查。

于 2009-08-10T17:54:23.513 回答
0

另外我建议将waitBoolean标记为volatile,但是您必须使用条件甚至更好的障碍。

于 2012-08-31T15:14:04.400 回答