如何验证条件变量是否已初始化？

我在解决获取锁定时出现的竞争条件时遇到了一些麻烦。我有一个异步触发的大型计算。我需要我的上一个同步任务在大任务开始之前结束。大任务启动并等待条件变量，并且在理想的情况下，小任务会在条件变量完成时通知条件变量。我的问题来自大任务太快，小任务触发条件变量尚未完全初始化，因此不会实际触发，导致程序被锁定。如何验证条件变量是否已初始化？

我把它煮到这个最小的例子。

我会认为这是一个常见问题。我怎样才能检查我的条件变量实际上是否拥有一个互斥锁并被锁定？

#include <QCoreApplication> 
#include <QObject> 
#include <QFuture> 
#include <QtConcurrent/QtConcurrent> 
#include <QFutureWatcher> 
#include <QWaitCondition> 

class workUnit: public QObject 
{ 
    Q_OBJECT 

    public: 
    workUnit(QObject *parent) 
    { 
     m = new QMutex(); 
     m->lock(); 
     w=new QWaitCondition(); 
    } 
    QWaitCondition* w; 
    QMutex* m; 

public slots: 
    void runMe() 
    { 
     w->wait(m); 
     m->unlock(); 
     //perform long computation 
    } 
}; 


int main(int argc, char *argv[]) 
{ 
    QCoreApplication a(argc, argv); 
    workUnit* mUnit=new workUnit(&a); 
    QFutureWatcher<void> w; 
    QObject::connect(&w, SIGNAL(finished()), &a, SLOT(quit())); 
    QFuture<void> f = QtConcurrent::run(mUnit,&workUnit::runMe); 
    w.setFuture(f); 
    _sleep(1000);//with this delay it works, without the delay it doesn't 
    mUnit->w->wakeAll();//This would be triggered by another process 
    return a.exec(); 
}

来源

2013-03-16 Mikhail

为QWaitCondition::wait的文档指出：

互斥锁必须是最初由调用线程锁定。

你应该从构造函数中删除m->lock();并把它放在runMe()函数调用wait之前。

来源

2013-03-16 22:58:13 alexisdm

如何验证条件变量是否已初始化？

回答

相关问题