同時運行的QThread中的插槽

Question

我有兩個類Handler和一個Worker與信號和插槽連接。下面是一個簡化版本（僞代碼）：

處理程序構造：

Handler::Handler(QObject *parent) : QObject(parent) 
{ 
    m_workerThread = new QThread; 
    m_worker = new Worker; 
    m_worker->moveToThread(m_workerThread); 
    m_workerThread->start(); 

    connect(this, &Handler::doWork, m_worker, &Worker::doWork); 
    connect(this, &Handler::stopWork, m_worker, &Worker::stopWork); 

    emit doWork(); 
} 

工人

void Worker::doWork() 
{ 
    qDebug()<<"------" 
    qDebug()<<"Start do work executing in: "<<QThread::currentThreadId(); 
    //doing some work 
    m_timer->start();//a singleshot timer that calls doWork() on timeout 
    qDebug()<<"work done"; 
    qDebug()<<"------" 

} 

void Worker::stopWork() 
{ 
    qDebug()<<"Stop timer executing in: "<<QThread::currentThreadId(); 
    m_timer->stop(); 
} 

所以基本上工作從處理器發射 「的doWork」 後開始。 「doWork」插槽有一個單點定時器，在一段時間後再次調用相同的功能。 一段時間後，處理程序發出「停止工作」信號。 這裏是我的調試輸出：

------ 
Start do work executing in: 0x65602450 
work done 
------ 
------ 
Start do work executing in: 0x65602450 
work done 
------ 
------ 
Start do work executing in: 0x65602450 
work done 
------ 
------ 
Start do work executing in: 0x65602450 
stop work emitted from handler in: 0x750a7000 
Stop timer executing in: 0x65602450 
work done 
------ 
------ 
Start do work executing in: 0x65602450 
work done 
------ 
etc... 

因此，我不明白是怎麼回事，甚至有可能是我的工作線程執行在同一時間兩個插槽（的doWork和限緊）？在執行「stopWork」插槽之前，不應該發佈stopWork信號並等待線程變爲空閒狀態嗎？

不幸的是，我不能用最小的工作示例重現這一點，但我希望從我發佈的代碼中清楚明白我失蹤的內容。

同樣從我的測試中我發現這是30-40％的時間。

Answer 1

使用像QMutex和/或QSemaphore這樣的線程同步類可以解決您的問題。

例如，如果你已經在你的處理程序類創建的QMutex，並傳遞給你的工作線程：

void Worker::doWork(QMutex* mutex) 
{ 
    mutex->lock(); 
    qDebug()<<"------" 
    qDebug()<<"Start do work executing in: "<<QThread::currentThreadId(); 
    //doing some work 
    m_timer->start();//a singleshot timer that calls doWork() on timeout 
    qDebug()<<"work done"; 
    qDebug()<<"------" 
    mutex->unlock(); 

} 

：

Handler::Handler(QObject *parent) : QObject(parent) 
{ 
    //Class variable : QMutex* mutex 
    mutex = new QMutex(); 
    m_workerThread = new QThread; 
    m_worker = new Worker; 
    m_worker->moveToThread(m_workerThread); 
    m_workerThread->start(); 

    connect(this, &Handler::doWork, m_worker, &Worker::doWork); 
    connect(this, &Handler::stopWork, m_worker, &Worker::stopWork,Qt::BlockingQueuedConnection); 

    emit doWork(mutex); 
} 

，然後從另一個線程中調用這個共同QMutex的鎖機制

而且使用相同的邏輯在你的Handler類，你發出「停止」信號之前：

... 
mutex->lock(); 
emit stopWork(); 
mutex->unlock(); 
... 

這樣你可以避免不必要的併發。

BlockingQueuedConnection標誌在這裏確保您的主線程不會在沒有停止作業的情況下前進完成，因此在作業完成之前不會解鎖互斥量。

這是我試圖在處理併發情況和數據競爭時使用的邏輯，我希望它也能幫助你。