实时追踪高频更新文件时PyQt4程序崩溃问题求助

看起来你遇到了典型的Qt跨线程GUI操作+IO处理不当的问题，我帮你拆解一下原因，然后给出完整的修复方案：

问题根源分析 #

1. Qt GUI线程安全问题：Qt规定所有GUI控件的操作必须在主线程（也就是创建控件的线程）中执行。你在子线程tailFile里直接调用textbox01.append()，这会破坏Qt控件的内部状态，尤其是当大量数据突发时，控件的事件队列和内部数据结构会出现冲突，就会抛出QObject::connect: Cannot queue arguments of type 'QTextCursor'和ASSERT failure in QVector<T>::operator[]这类错误。
2. IO处理逻辑缺陷：你虽然初始化了select.poll，但根本没用到它来监听子进程的输出状态，直接循环调用readline()会导致线程阻塞，或者当子进程一次性输出大量数据时，读取和处理不及时，进一步加剧GUI线程的冲突。

修复方案 #

我们需要用Qt的信号槽机制实现跨线程通信，同时正确处理子进程的IO输出，确保所有GUI操作都在主线程执行。

完整修复代码 #

import sys
import os
import select
import subprocess
import time
import threading
from PyQt4.QtGui import QApplication, QMainWindow, QTextEdit, QVBoxLayout, QWidget
from PyQt4.QtCore import QObject, pyqtSignal, Qt

class LogTracker(QObject):
    # 自定义信号：传递文本框标识和要追加的内容
    update_text = pyqtSignal(str, str)

class MainWindow(QMainWindow):
    def __init__(self):
        super(MainWindow, self).__init__()
        self.init_ui()
        self.should_run = True
        self.log_tracker = LogTracker()
        # 绑定信号到槽函数，用队列连接确保主线程处理
        self.log_tracker.update_text.connect(self.append_to_textbox, Qt.QueuedConnection)
        # 启动日志追踪线程
        self.tail_thread = threading.Thread(target=self.tail_files)
        self.tail_thread.start()

    def init_ui(self):
        self.setWindowTitle("Log Tracker")
        central_widget = QWidget()
        layout = QVBoxLayout(central_widget)
        # 创建两个只读文本框
        self.textbox01 = QTextEdit()
        self.textbox01.setReadOnly(True)
        self.textbox02 = QTextEdit()
        self.textbox02.setReadOnly(True)
        layout.addWidget(self.textbox01)
        layout.addWidget(self.textbox02)
        self.setCentralWidget(central_widget)
        self.resize(800, 600)

    def append_to_textbox(self, box_id, content):
        # 主线程中安全操作GUI控件
        if box_id == "box1" and content:
            self.textbox01.append(content.strip())
        elif box_id == "box2" and content:
            self.textbox02.append(content.strip())

    def tail_files(self):
        # 启动tail子进程，修正原代码的拼写错误preexec_fn
        file1 = subprocess.Popen(
            ['tail', '-F', 'FILENAME1'],
            stdout=subprocess.PIPE,
            preexec_fn=os.setsid,
            encoding='utf-8'  # 直接解码为字符串，避免字节处理
        )
        poll1 = select.poll()
        poll1.register(file1.stdout, select.POLLIN)

        file2 = subprocess.Popen(
            ['tail', '-F', 'FILENAME2'],
            stdout=subprocess.PIPE,
            preexec_fn=os.setsid,
            encoding='utf-8'
        )
        poll2 = select.poll()
        poll2.register(file2.stdout, select.POLLIN)

        while self.should_run:
            # 检查file1是否有数据可读，100ms超时避免线程阻塞
            events1 = poll1.poll(100)
            for fd, event in events1:
                if event & select.POLLIN:
                    line = file1.stdout.readline()
                    self.log_tracker.update_text.emit("box1", line)

            # 检查file2是否有数据可读
            events2 = poll2.poll(100)
            for fd, event in events2:
                if event & select.POLLIN:
                    line = file2.stdout.readline()
                    self.log_tracker.update_text.emit("box2", line)

            time.sleep(0.01)  # 轻微延迟降低CPU占用

        # 清理子进程，避免残留
        os.killpg(os.getpgid(file1.pid), 9)
        os.killpg(os.getpgid(file2.pid), 9)
        file1.wait()
        file2.wait()

    def closeEvent(self, event):
        # 程序关闭时优雅终止线程和子进程
        self.should_run = False
        self.tail_thread.join()
        event.accept()

if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = MainWindow()
    window.show()
    sys.exit(app.exec_())

关键修复点说明 #

1. 信号槽跨线程通信：
   • 定义update_text信号，子线程读取到日志后发射信号，主线程的append_to_textbox槽函数负责更新文本框，确保所有GUI操作都在主线程执行。
   • 使用Qt.QueuedConnection将信号放入主线程事件队列，彻底避免并发冲突。
2. 正确使用select.poll：
   • 用poll()监听子进程stdout的可读状态，只有当有数据时才读取，避免线程阻塞。设置100ms超时，确保线程能及时响应终止信号。
3. 子进程资源清理：
   • 程序关闭时先终止线程，再杀死子进程组（因os.setsid创建了独立进程组），避免残留后台进程。
4. 细节修正：
   • 修复原代码中preecec_fn的拼写错误。
   • 给subprocess指定编码，直接读取字符串简化处理。
   • 设置文本框为只读，防止用户误操作。

额外优化建议 #

如果日志突发量极大，还可以做以下优化：

• 批量更新：在子线程中攒够N行日志再发射一次信号，减少GUI更新频率，避免界面卡顿。
• 限制日志行数：用self.textbox01.document().setMaximumBlockCount(10000)限制文本框只保留最近10000行，防止内存占用过高。

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