QSystemSemaphore::acquire() 中止

Question

我使用 QSharedMemory 和 QSystemSemaphore 来组织多个进程之间的事件交换。 QSharedMemory 存储接收器的数量和事件数据。接收者在 QSystemSemaphore::acquire() 中等待。发送者通过 QSystemSemaphore::release([接收者数量]) 通知他们。

除了在共享内存中引入标志“real”/“fake”并随后在终止进程中生成“fake”事件之外，还有什么方法可以优雅地终止接收进程？

Answer 1

QThread::terminate() 可以在每个平台上运行，无论线程目前正在做什么。当然，当您终止应用程序中的任何线程时，您唯一可以安全地做的另一件事就是调用abort：此时进程通常处于中断状态。 请勿在致电QThread::terminate 后执行abort()-ing 以外的任何操作。既然破坏力太大，不如放弃调用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.
}