如何在存在待处理QueuedConnection信号时干净退出QThread？

场景与代码实现 #

我用DataHandler封装了DataReceiver和DataProcessor两个QObject对象，二者分别运行在独立线程中：

DataReceiver的run函数实现 #

DataReceiver::run()
{
    this->stop = false;
    while(!stop)
    {
      // 接收数据逻辑
      emit data_ready(data);
    }
}

DataHandler类结构 #

class DataHandler
{
    public:
      DataHandler();
      ~DataHandler();

    private:
      QThread data_processing_thread;
      QThread data_receiver_thread;

      DataReceiver data_receiver;
      DataProcessor data_processor;
};

构造函数的信号槽与线程绑定 #

DataHandler::DataHandler() {
    connect(&data_receiver_thread, &QThread::started, &data_receiver,
            &DataReceiver::run);

    connect(&data_receiver, &DataReceiver::data_ready, &data_processor,
            &DataProcessor::process);

    data_receiver.moveToThread(&data_receiver_thread);
    data_processor.moveToThread(&data_processing_thread);

    data_receiver_thread.start();
    data_processing_thread.start();
}

当前退出逻辑 #

当DataHandler即将超出作用域时，DataReceiver已发送200个data_ready信号，但DataProcessor处理速度不足，仍有大量待处理信号，当前析构函数实现如下：

DataHandler::~DataHandler() {

    data_receiver.stop = true; // 通知data_receiver退出循环
    data_receiver_thread.quit();
    data_receiver_thread.wait();

    data_processing_thread.quit();
    data_processing_thread.wait();

} // data_receiver和data_processor在此处超出作用域

疑问与需求 #

• 未处理的待处理信号会如何处理？是在data_processor或data_processor_thread超出作用域时被清除吗？
• 是否存在更干净的退出方式？
• 停止时希望取消剩余待处理信号以实现快速停止，同时尽可能避免内存泄漏。

解答 #

未处理信号的默认行为 #

调用data_processing_thread.quit()后，线程事件循环会退出，但队列中未处理的data_ready信号不会自动清除。这些信号会留在Qt的事件队列中，直到data_processor被销毁——当data_processor在DataHandler析构末尾超出作用域时，Qt会自动清理所有针对该对象的待处理信号，不会因此产生内存泄漏。

但要注意：如果data_ready信号携带的是堆分配对象（比如new出来的data），且DataProcessor::process是唯一负责释放这些对象的逻辑，那么未处理信号中的data会因为没被处理而泄漏，这种情况需要额外处理。

更干净的快速退出方案 #

要实现快速停止并清除待处理信号，推荐按以下步骤操作：

1. 切断信号源，停止新信号产生
   先设置data_receiver.stop = true并等待接收线程退出，确保不再生成新的data_ready信号，这一步你当前的实现已经没问题。

2. 断开信号槽连接，清除待处理信号
   在等待处理线程退出前，断开data_receiver与data_processor的信号槽连接：

   disconnect(&data_receiver, &DataReceiver::data_ready, &data_processor, &DataProcessor::process);
   

   断开连接后，Qt会立即清理队列中所有未处理的该信号，避免后续不必要的处理。

3. 处理长时间运行的任务（可选）
   如果DataProcessor::process包含长时间执行的逻辑，调用quit()后wait()可能会卡住。这种情况下，可以先调用data_processing_thread.requestInterruption()，然后在DataProcessor::process中定期检查QThread::currentThread()->isInterruptionRequested()，主动退出处理逻辑，最后再调用quit()和wait()。

4. 管理信号携带的堆内存
   如果data是堆分配的，建议改用智能指针（比如std::unique_ptr）作为信号参数，确保即使信号未被处理，内存也能自动释放；或者在断开连接后，手动清理待处理信号中的数据。

优化后的析构函数示例 #

DataHandler::~DataHandler() {
    // 停止接收线程，不再产生新信号
    data_receiver.stop = true;
    data_receiver_thread.quit();
    data_receiver_thread.wait();

    // 断开信号连接，清除待处理的data_ready信号
    disconnect(&data_receiver, &DataReceiver::data_ready, &data_processor, &DataProcessor::process);

    // 停止处理线程
    data_processing_thread.quit();
    data_processing_thread.wait();
}

内容的提问来源于stack exchange，提问作者cwbusacker