PySide6中JZWorker的QThread finished信号未触发及崩溃问题

问题根源分析 #

• finished信号未触发：通常是QThread的finished信号未正确连接，或线程/Worker对象被提前销毁导致信号无法传递；也可能是Worker未正确移入线程，或任务完成后未发射结束信号。
• 设为None崩溃：线程或Worker仍在运行时就被强制销毁，或信号连接未断开，引发内存访问错误。

具体修复步骤 #

1. 正确绑定Worker与线程的生命周期 #

在JZWorker初始化时，必须完成Worker移线程、信号绑定的核心逻辑，确保信号能正常传递：

from PyQt5.QtCore import QThread, QObject, pyqtSignal, pyqtSlot

class JZWorker:
    def __init__(self, worker_class, *args, **kwargs):
        self._thread = QThread()
        self._worker = worker_class(*args, **kwargs)
        # 将Worker移入子线程
        self._worker.moveToThread(self._thread)
        # 线程启动时触发Worker的run方法
        self._thread.started.connect(self._worker.run)
        # Worker完成后，终止线程并销毁自身
        self._worker.finished.connect(self._thread.quit)
        self._worker.finished.connect(self._worker.deleteLater)
        # 线程结束后销毁自身
        self._thread.finished.connect(self._thread.deleteLater)

    def start(self):
        self._thread.start()

    def stop(self):
        if hasattr(self._worker, 'stop'):
            self._worker.stop()

2. Worker类必须实现结束信号与停止逻辑 #

Worker需继承QObject，定义finished信号，任务完成后主动发射；同时实现停止方法，让任务能优雅终止：

class Worker(QObject):
    finished = pyqtSignal()
    _is_running = True

    def run(self):
        # 示例异步任务逻辑
        while self._is_running:
            # 执行任务代码，比如耗时计算
            pass
        # 任务结束后必须发射finished信号
        self.finished.emit()

    def stop(self):
        self._is_running = False

3. 优雅处理Stop按钮逻辑 #

点击Stop时，不能直接将worker设为None，需先触发停止、等待线程结束、断开信号后再清理：

# 假设在主窗口类中
def on_stop_btn_clicked(self):
    if self.worker:
        # 触发Worker停止逻辑
        self.worker.stop()
        # 等待线程完全结束
        self.worker._thread.wait()
        # 断开所有信号连接，避免悬空引用
        self.worker._thread.disconnect()
        self.worker._worker.disconnect()
        # 最后清理对象
        self.worker = None

关键注意事项 #

• 禁止在子线程中直接操作UI，所有UI更新必须通过信号槽机制传递到主线程处理。
• 始终使用deleteLater()延迟销毁对象，确保所有信号处理流程完成后再释放内存。
• 线程启动必须调用QThread.start()，而非直接调用Worker的run方法（否则会在主线程执行）。

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