QSystemSemaphore :: acquire（）abort

Question

我使用QSharedMemory和QSystemSemaphore來組織多個進程之間的事件交換。 QSharedMemory存儲接收器和事件數據的數量。接收者正在等待QSystemSemaphore :: acquire（）。發件人通過QSystemSemaphore :: release（[接收器數量]）通知他們。

除了在共享內存中引入標誌「真實」/「假」並隨後在終止過程中生成「假」事件之外，是否有任何方法可以正常終止接收過程？

Answer 1

QThread::terminate()適用於任何平臺，無論此刻線程在做什麼。當然，如果您在應用程序中終止了任意線程，則唯一可以安全執行的其他操作是調用abort：此時該進程通常處於中斷狀態。 不要做任何事情，除了abort() - 在您撥打QThread::terminate後。由於它具有很強的破壞性，因此您最好不要撥打terminate並直接中止。

在致電terminate後，您的問題就好像您有計劃繼續使用該應用程序一樣。你不能！

唉，如果您只想讓一個線程退出，信號量是一個同步原語，您可以通過設置一個標誌並釋放信號量來輕鬆完成。下面是一個有點人爲的例子，因爲你通常不會這樣使用線程池：它只是縮短代碼。

// https://github.com/KubaO/stackoverflown/tree/master/questions/semaphore-quit-40488523 
#include <QtCore> 

class Worker : public QRunnable { 
    static const QString m_key; 
    static QAtomicInteger<bool> m_abort; 
    void run() override { 
     QSystemSemaphore sem{m_key}; 
     qDebug() << "working"; 
     while (true) { 
      sem.acquire(); 
      if (m_abort.load()) { 
       sem.release(); 
       qDebug() << "aborting"; 
       return; 
      } 
      sem.release(); 
     } 
    } 
public: 
    static void acquire(int n = 1) { 
     QSystemSemaphore sem{m_key}; 
     while (n--) 
      sem.acquire(); 
    } 
    static void release(int n = 1) { 
     QSystemSemaphore{m_key}.release(n); 
    } 
    static void quit(int n) { 
     m_abort.store(true); 
     release(n); 
    } 
}; 
const QString Worker::m_key = QStringLiteral("semaphore-quit-40488523"); 
QAtomicInteger<bool> Worker::m_abort = false; 

int main() 
{ 
    QThreadPool pool; 
    QVarLengthArray<Worker, 20> workers{20}; 
    for (auto & worker : workers) { 
     worker.setAutoDelete(false); 
     pool.start(&worker); 
    } 
    Worker::release(workers.size()); // get some workers churning 
    QThread::sleep(5); 
    Worker::acquire(workers.size()); // pause all the workers 
    Worker::quit(workers.size()); 
    // The thread pool destructor will wait for all workers to quit. 
}