PyQt Worker中途停止时未触发finished信号问题咨询

最小可复现示例（MVCE） #

# importing libraries
from PyQt6.QtWidgets import * 
from PyQt6.QtGui import * 
from PyQt6.QtCore import * 
import sys
import time

class Worker(QObject):
    finished = pyqtSignal()
    _stop = False
    def run(self):
        i=0
        print('Started')
        for i in range(5):
            if self._stop:
                print('Breaking')
                break
            time.sleep(1)
            i+=1
        self.finished.emit()
        print('Done')
    
    def stop(self):
        self._stop = True
        

class Example(QWidget):
  
    def __init__(self):
        super().__init__()
        self.initUI()
  
    def initUI(self):
        try:
            self.worker.stop()
            self.thread.wait()
        except (RuntimeError,AttributeError):
            pass
        print('Here')
        self.createThread()
        self.thread.started.connect(self.worker.run)
        self.worker.quit = False
        self.thread.finished.connect(lambda:print('Stopped'))
        self.thread.start()

        self.btn = QPushButton(self)
        self.btn.move(40, 80)
        self.btn.setText('Stop')
        self.btn.clicked.connect(self.initUI)
        self.setWindowTitle("Python")
        self.show()

    def createThread(self):
        self.thread = QThread()
        self.worker = Worker()
        self.worker.moveToThread(self.thread)
        self.worker.finished.connect(self.thread.quit)
        self.worker.finished.connect(self.worker.deleteLater)
        self.thread.finished.connect(self.thread.deleteLater)
  
if __name__ == '__main__':    
    App = QApplication(sys.argv)
    window = Example()
    sys.exit(App.exec())

问题描述 #

initUI函数会创建一个带按钮的窗口，同时启动一个线程执行5次循环，每次休眠1秒。点击按钮会再次调用initUI，此时若线程仍在运行，会调用worker.stop()中途停止线程。但此时明明worker.run函数已经执行完毕，finished信号却没触发；而等循环自行跑完5秒时，信号能正常触发。这是什么原因？

核心原因：主线程被阻塞+实例被覆盖 #

问题出在initUI里的self.thread.wait()和后续的实例覆盖操作：

1. 点击按钮调用worker.stop()后，worker的循环跳出，准备触发finished信号，但紧接着self.thread.wait()会完全阻塞主线程——Qt的信号传递依赖事件循环，主线程被卡就没法处理信号分发。
2. 原线程结束后主线程从wait()恢复，立刻调用createThread()，新的self.worker和self.thread直接覆盖了旧实例。旧worker就算后续能触发finished信号，对应的槽函数（比如thread.quit）已经绑定到旧线程实例，现在旧实例被覆盖，信号自然无人响应。

错误流程拆解 #

• 点击按钮→调用worker.stop()→worker循环跳出，准备发finished信号
• 执行thread.wait()→主线程卡死，无法处理任何事件（包括信号）
• 原线程结束→主线程恢复→立刻创建新的worker和线程，覆盖旧实例
• 旧worker的finished信号此时再触发，已经没有有效槽函数接收

修正方案 #

抛弃thread.wait()，改用Qt的信号机制处理线程结束逻辑，避免阻塞主线程和实例覆盖：

修改后的关键代码：

def initUI(self):
    need_restart = False
    # 检查是否有正在运行的线程
    if hasattr(self, 'thread') and self.thread.isRunning():
        self.worker.stop()
        need_restart = True
        # 线程结束后再重新创建新线程
        def restart_thread():
            self.createThread()
            self._setup_thread_connections()
            self.thread.start()
        self.thread.finished.connect(restart_thread)
    else:
        # 首次初始化或线程已结束，直接创建启动线程
        self.createThread()
        self._setup_thread_connections()
        self.thread.start()

    # 避免重复创建按钮
    if not hasattr(self, 'btn'):
        self.btn = QPushButton(self)
        self.btn.move(40, 80)
        self.btn.setText('Stop')
        self.btn.clicked.connect(self.initUI)
    self.setWindowTitle("Python")
    self.show()

# 抽离线程信号连接逻辑，减少重复代码
def _setup_thread_connections(self):
    self.thread.started.connect(self.worker.run)
    self.thread.finished.connect(lambda:print('Stopped'))
    self.worker.finished.connect(self.thread.quit)
    self.worker.finished.connect(self.worker.deleteLater)
    self.thread.finished.connect(self.thread.deleteLater)

额外注意事项 #

• 不要在worker里用time.sleep()，改用QThread.sleep()，避免阻塞线程的事件响应能力
• 不要重复创建UI元素，多次调用initUI会生成多个按钮，导致界面混乱
• 线程和worker的属性操作要确保逻辑顺序，避免未清理旧实例就覆盖

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