PyQt6中多对话框下终止长时间运行操作的问题

你的核心问题在于任务没有真正在子线程中执行，导致主线程被阻塞，取消对话框无法响应。以下是具体问题分析和修复方案：

问题根源 #

1. 直接调用Worker方法，未触发子线程执行：虽然将Worker移到了QThread，但直接调用self.worker.task()是在主线程执行的，信号槽机制才是PyQt跨线程调用方法的正确方式。
2. 任务未检查停止标志：Worker的task方法里没有定期检查_isRunning，无法中途终止操作。
3. 主线程被阻塞：end_thread中的self.thread.wait()会阻塞主线程，导致界面冻结。

修复方案 #

• 给Worker添加start信号，通过信号触发task方法，确保任务在子线程运行。
• 在task的延迟过程中定期检查_isRunning标志，支持中途取消。
• 使用QThread.sleep()替代time.sleep()（子线程中使用Qt的方法更安全）。
• 移除主线程中的thread.wait()，让线程自然退出，避免阻塞GUI。

修正后的代码 #

import sys
from PyQt6.QtCore import *
from PyQt6.QtWidgets import *


class ConnectionDialog(QDialog):
    def __init__(self):
        super().__init__()
        self.database = -1
        self.setFixedSize(QSize(200, 100))

        self.cancel_dialog = CancelDialog(self)

        # 初始化线程和Worker
        self.thread = QThread()
        self.worker = Worker()
        self.worker.moveToThread(self.thread)

        # 信号连接：启动任务、任务结束、线程结束
        self.btnStart = QPushButton("Connect")
        self.btnStart.clicked.connect(self.start_worker)
        self.worker.start.connect(self.worker.task)
        self.worker.finished.connect(self.on_worker_finished)
        self.thread.finished.connect(self.thread.deleteLater)  # 线程结束后释放资源

        layout = QHBoxLayout()
        layout.addWidget(self.btnStart)
        self.setLayout(layout)

    def start_worker(self):
        self.cancel_dialog.show()
        self.thread.start()  # 启动线程
        self.worker.start.emit()  # 触发Worker开始任务

    def on_worker_finished(self, connection):
        self.thread.quit()  # 请求线程退出
        self.database = connection
        print(f"Connected to {connection}" if connection != -1 else "Canceled")
        self.cancel_dialog.close()
        self.close()


class CancelDialog(QDialog):
    def __init__(self, parent):
        super().__init__(parent)
        self.setModal(True)
        self.setWindowTitle("Connecting...")
        self.btnStop = QPushButton("Cancel")
        self.btnStop.clicked.connect(self.cancel_thread)

        layout = QHBoxLayout()
        layout.addWidget(self.btnStop)
        self.setLayout(layout)

    def cancel_thread(self):
        self.parent().worker.stop()
        self.parent().database = -1
        print("Canceled")
        self.close()


class Worker(QObject):
    start = pyqtSignal()
    finished = pyqtSignal(int)

    def __init__(self):
        super().__init__()
        self._isRunning = True
        self.connection = -1

    def task(self):
        self._isRunning = True
        self.connection = -1
        print("connecting...")
        
        # 模拟连接前延迟，检查停止标志
        print("fake delay before connection")
        for _ in range(30):  # 分30次检查，每次0.1秒，总延迟3秒
            if not self._isRunning:
                self.finished.emit(self.connection)
                return
            QThread.msleep(100)
        
        if not self._isRunning:
            self.finished.emit(self.connection)
            return
        
        print("really connecting now")
        self.connection = 123
        
        # 模拟连接后延迟，检查停止标志
        print("fake delay after connection")
        for _ in range(30):
            if not self._isRunning:
                self.connection = -1
                self.finished.emit(self.connection)
                return
            QThread.msleep(100)
        
        print("finished connecting")
        self.finished.emit(self.connection)

    def stop(self):
        self._isRunning = False
        print("Stopping connection attempt...")


if __name__ == "__main__":
    app = QApplication(sys.argv)
    simul = ConnectionDialog()
    simul.show()
    sys.exit(app.exec())

关键改进点 #

1. 信号触发任务：通过worker.start信号触发task方法，确保任务在子线程执行，不会阻塞主线程。
2. 分阶段检查停止标志：将长延迟拆分为多个短延迟，每次延迟后检查_isRunning，确保取消操作能及时响应。
3. 线程资源管理：使用thread.finished.connect(self.thread.deleteLater)自动释放线程资源，避免内存泄漏。
4. 移除主线程阻塞操作：取消thread.wait()，让线程自然退出，保证GUI始终响应。

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