PyQt6中Watchdog事件触发QMessageBox崩溃/无响应问题求助

问题根源 #

Watchdog的Observer运行在独立子线程中，事件回调（如on_created、on_modified）默认在子线程执行。而PyQt的所有UI操作**必须在主线程（QApplication事件循环所在线程）**中进行，子线程直接调用QMessageBox会导致线程上下文冲突，出现界面无响应、内容不显示甚至程序崩溃的情况。

按钮点击的回调本身就在主线程执行，所以不会出现问题。

解决方案：线程间通信转主线程执行UI操作 #

PyQt提供两种标准方式将子线程的UI操作请求转到主线程处理：

方法1：使用信号与槽（推荐，符合PyQt设计模式）

给事件处理器定义PyQt信号，文件事件触发时发射信号，主窗口的槽函数在主线程接收信号并显示弹窗。修改后的完整代码：

import sys
import os
from PyQt6.QtWidgets import QApplication, QWidget, QPushButton, QMessageBox
from PyQt6.QtCore import pyqtSignal, QObject
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler

# 带信号的事件处理器
class Handler(FileSystemEventHandler, QObject):
    # 定义对应文件创建、修改的信号
    file_created = pyqtSignal(str)
    file_modified = pyqtSignal(str)

    def __init__(self, observer):
        QObject.__init__(self)
        self.observer = observer
        super().__init__()

    def on_created(self, event):
        if not event.is_directory:
            self.observer.stop()
            self.observer.unschedule_all()
            # 发射信号传递文件路径
            self.file_created.emit(event.src_path)

    def on_modified(self, event):
        if not event.is_directory:
            self.observer.stop()
            self.observer.unschedule_all()
            # 发射信号传递文件路径
            self.file_modified.emit(event.src_path)

class App(QWidget):
    def __init__(self):
        super().__init__()
        self.title = 'Watchdog App'
        self.left = 100
        self.top = 100
        self.width = 300
        self.height = 200
        self.initUI()

    def initUI(self):
        self.setWindowTitle(self.title)
        self.setGeometry(self.left, self.top, self.width, self.height)

        self.btn_start = QPushButton('Iniciar', self)
        self.btn_start.move(50, 50)
        self.btn_start.clicked.connect(self.start_watchdog)

        self.btn_stop = QPushButton('Detener', self)
        self.btn_stop.move(150, 50)
        self.btn_stop.clicked.connect(self.stop_watchdog)

        self.show()

    def start_watchdog(self):
        path = os.path.join(os.getenv("USERPROFILE"), "Downloads")
        self.observer = Observer()
        self.event_handler = Handler(self.observer)
        # 连接信号到主线程的槽函数
        self.event_handler.file_created.connect(self.show_created_msg)
        self.event_handler.file_modified.connect(self.show_modified_msg)
        self.observer.schedule(self.event_handler, path, recursive=True)
        self.observer.start()
        print(f"Watchdog activo: {self.observer.is_alive()}")

    def stop_watchdog(self):
        self.observer.stop()
        self.observer.unschedule_all()
        self.observer.join()
        print(f"Watchdog activo: {self.observer.is_alive()}")

    # 主线程执行的弹窗函数
    def show_created_msg(self, file_path):
        QMessageBox.information(self, "Archivo creado", f"Se creó el archivo: {file_path}")

    def show_modified_msg(self, file_path):
        QMessageBox.information(self, "Archivo modificado", f"Se modificó el archivo: {file_path}")

if __name__ == '__main__':
    app = QApplication(sys.argv)
    ex = App()
    sys.exit(app.exec())

方法2：使用QMetaObject.invokeMethod

如果不想用信号槽，可直接在子线程回调中调用该方法，强制在主线程执行UI操作：

# 修改Handler的on_created方法示例
def on_created(self, event):
    if not event.is_directory:
        self.observer.stop()
        self.observer.unschedule_all()
        from PyQt6.QtCore import QMetaObject, Qt
        # 强制在主线程执行弹窗逻辑
        QMetaObject.invokeMethod(
            QApplication.instance(), 
            lambda: QMessageBox.information(None, "Archivo creado", f"Se creó el archivo: {event.src_path}"),
            Qt.ConnectionType.QueuedConnection
        )

额外注意事项 #

• 处理事件时判断event.is_directory，避免目录操作的冗余触发
• 停止Observer的操作可放在主线程执行（如信号槽回调中），进一步规避线程冲突
• 若需持续监听，可在弹窗关闭后重新启动Observer

内容的提问来源于stack exchange，提问作者Ricardo Garcia Ramirez