如何正确退出需清理资源的事件驱动线程？

当通过QStateMachine触发stop时，stop()槽在主线程执行，调用spy.wait()会阻塞主线程的事件循环。而ready_to_abort是子线程发出的跨线程信号，需要主线程事件循环处理才能被QSignalSpy捕获。主线程被阻塞后无法处理该信号，导致spy.wait()超时，后续调用workerThread.wait()时，子线程因事件循环未正确退出而引发程序挂起。

避免在主线程槽函数中使用阻塞等待，改用信号槽异步处理退出流程，确保主线程事件循环不被阻塞，同时保证子线程资源清理完成后再退出线程。

修改后的完整代码 #

from PyQt5.QtCore import QObject, QThread, Slot, Signal, QState, QStateMachine
from PyQt5.QtWidgets import QMainWindow, QApplication
import sys

class Worker(QObject):
    ready_to_abort = Signal()
    # 通知主线程：资源已清理完成，可以退出线程
    thread_cleanup_finished = Signal()

    def __init__(self, parent=None):
        super(Worker, self).__init__(parent)
        self.__abort_requested = False

    @Slot()
    def process(self):
        if self.__abort_requested:
            return

    @Slot()
    def abort(self):
        self.__abort_requested = True
        print('开始停止并清理资源')
        # 执行真实的资源清理逻辑：关闭文件、释放句柄、销毁对象等
        self._cleanup_resources()
        self.ready_to_abort.emit()
        # 清理完成后发出信号，触发线程退出流程
        self.thread_cleanup_finished.emit()

    def _cleanup_resources(self):
        # 替换为实际的资源清理代码
        pass

class Process(QObject):
    __abortWorker = Signal()
    # 通知上层：线程已完全退出
    thread_exit_finished = Signal()

    def __init__(self, parent=None):
        super(Process, self).__init__(parent)
        self.worker = Worker()
        self.workerThread = QThread()
        self.worker.moveToThread(self.workerThread)
        # 连接信号：资源清理完成 → 执行线程退出
        self.worker.thread_cleanup_finished.connect(self._quit_thread)
        # 线程退出完成 → 发出上层通知信号
        self.workerThread.finished.connect(self.thread_exit_finished)

    @Slot()
    def run(self):
        self.__abortWorker.connect(self.worker.abort)
        self.workerThread.start()

    @Slot()
    def stop(self):
        # 仅发出中止信号，不阻塞，等待异步回调
        self.__abortWorker.emit()

    @Slot()
    def _quit_thread(self):
        print('线程退出前状态：', self.workerThread.isRunning())
        self.workerThread.quit()
        self.workerThread.wait()
        print('线程退出后状态：', self.workerThread.isRunning())
        self.thread_exit_finished.emit()

class MW(QMainWindow):
    def __init__(self):
        super(MW, self).__init__()
        self.m = QStateMachine()
        self.s = QState()
        self.m.addState(self.s)
        self.m.setInitialState(self.s)
        self.p = Process()
        self.m.started.connect(self.p.run)
        self.m.stopped.connect(self.p.stop)
        # 线程完全退出后，再关闭主窗口
        self.p.thread_exit_finished.connect(self._on_thread_exit)

    def showEvent(self, event):
        self.m.start()
        super().showEvent(event)

    def closeEvent(self, event):
        self.m.stop()
        # 先阻止默认关闭，等待线程退出完成
        event.ignore()

    @Slot()
    def _on_thread_exit(self):
        # 线程资源清理完成，正式关闭窗口
        self.close()

app = QApplication(sys.argv)
mw = MW()
mw.show()

sys.exit(app.exec())

关键修改说明 #

1. 移除阻塞等待：删除QSignalSpy和spy.wait()，改用thread_cleanup_finished信号触发线程退出，全程不阻塞主线程事件循环。
2. 异步流程拆分：将资源清理、线程退出、窗口关闭拆分为独立的信号驱动步骤，确保每一步完成后再执行下一步。
3. 线程安全保障：所有Worker的操作（包括资源清理）都在子线程执行，避免跨线程直接操作资源引发的线程安全问题。
4. 窗口关闭控制：在closeEvent中先阻止默认关闭逻辑，等待线程完全退出后再关闭窗口，保证资源清理彻底。

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