如何在PyQt6中安全停止运行中的QThread线程实例？

问题根源 #

你的StartProcessWorkerThread线程在run()方法中调用了阻塞的目标检测逻辑（main_driver_code），quit()/exit()仅能终止线程的事件循环，但你的线程并未运行事件循环，因此这两个方法无效。而terminate()会强制杀死线程，导致视频句柄、模型资源等未被正确释放，再次启动时因资源冲突引发崩溃。

正确解决方案：优雅停止线程 #

通过添加线程安全的停止标志，让线程在完成当前任务单元（比如单帧视频处理）后主动退出，确保资源正常释放。

1. 修改线程类，添加停止标志与停止方法 #

from PyQt6.QtCore import QThread, pyqtSignal

class StartProcessWorkerThread(QThread):
    processing_finished = pyqtSignal(dict)
    progress_updated = pyqtSignal(int)

    def __init__(self, input_video_filepaths, weapons_to_detect, clothings_to_detect_and_colors, username):
        super().__init__()
        self.input_video_filepaths = input_video_filepaths
        self.weapons_to_detect = weapons_to_detect
        self.clothings_to_detect_and_colors = clothings_to_detect_and_colors
        self.username = username
        self.is_running = True  # 线程安全的停止标志（主线程写，子线程读）

    def stop(self):
        # 主线程调用此方法设置停止标志
        self.is_running = False

    def run(self):
        try:
            table_data = self.run_main_driver_code()
            # 仅在未被强制停止时发送完成信号
            if self.is_running:
                self.processing_finished.emit(table_data)
        finally:
            # 确保无论是否正常退出，都完成资源清理（若有）
            pass

    def run_main_driver_code(self):
        user_specific_table_data = cwd.main_driver_code(
            input_video_filepaths=self.input_video_filepaths,
            weapons_to_detect=self.weapons_to_detect,
            clothings_to_detect_and_colors=self.clothings_to_detect_and_colors,
            username=self.username,
            progress_callback=self.progress_updated,
            stop_flag=self.is_running  # 将停止标志传入驱动函数
        )
        return user_specific_table_data

2. 修改main_driver_code，添加停止检查逻辑 #

在目标检测的循环处理中（比如逐帧处理视频时），定期检查停止标志，若标志为False则提前退出并释放资源：

def main_driver_code(input_video_filepaths, weapons_to_detect, clothings_to_detect_and_colors, username, progress_callback, stop_flag):
    # 初始化视频捕获、模型等资源
    video_capture = cv2.VideoCapture(input_video_filepaths[0])
    table_data = []
    total_frames = int(video_capture.get(cv2.CAP_PROP_FRAME_COUNT))
    
    while video_capture.isOpened():
        # 每次循环前检查停止标志
        if not stop_flag:
            break
            
        ret, frame = video_capture.read()
        if not ret:
            break
            
        # 执行目标检测逻辑...
        # 更新进度条
        current_frame = int(video_capture.get(cv2.CAP_PROP_POS_FRAMES))
        progress_callback.emit(int((current_frame / total_frames) * 100))
        # 收集检测结果到table_data...
    
    # 必须释放资源
    video_capture.release()
    return table_data

3. 主窗口添加停止按钮与逻辑 #

# 初始化停止按钮（假设已添加到UI布局）
self.stop_btn = QPushButton("停止检测")
self.stop_btn.clicked.connect(self.stop_detection)
self.stop_btn.setEnabled(False)

# 启动检测的方法中，启用停止按钮
def start_detection(self):
    # ... 创建worker实例的原有代码 ...
    self.worker.start()
    self.stop_btn.setEnabled(True)

# 停止检测的方法
def stop_detection(self):
    if hasattr(self, 'worker') and self.worker.isRunning():
        self.worker.stop()
        self.stop_btn.setEnabled(False)
        # 可添加提示："正在停止检测，请稍候..."

# 线程结束后清理worker实例
self.worker.finished.connect(lambda: setattr(self, 'worker', None))

关键注意事项 #

• 停止标志is_running是线程安全的：Python中bool类型的赋值为原子操作，主线程写、子线程读不会出现竞态问题。
• 若目标检测逻辑中存在第三方库的阻塞调用（如模型推理），需确保该库支持中断，或拆分任务为可检查停止标志的小单元。
• 必须在main_driver_code中显式释放所有资源（视频句柄、模型内存等），避免资源泄漏。

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