python - 将 stdout 和 stderr 从辅助线程重定向到 PyQt4 QTextEdit

Question

堆栈溢出。再一次，我在急需的时候来找你，在精神错乱的边缘摇摇欲坠。这个问题——从标题中可以看出——是我在这里看到的其他几个问题的合并。

我有一个 PyQt 应用程序，我想将 stdout 和 stderr 流重新路由到我的 GUI 中的 QTextEdit没有延迟。

最初，我找到了以下堆栈溢出答案: https://stackoverflow.com/a/17145093/629404

这很有效，但有一个警告:如果在 CPU 处理相对较长的方法时多次更新 stdout 或 stderr，所有更新都会在主线程返回应用程序循环时同时显示 。不幸的是，我有一些方法最多需要 20 秒才能完成(与网络相关)，因此应用程序变得无响应 - 并且 QTextEdit 不会更新 - 直到它们完成。

为了解决这个问题，我将所有的 GUI 处理委托(delegate)给主线程，并且我一直在产生第二个线程来处理更长的网络操作，使用 pyqtSignals 来通知主线程何时工作完成并传回结果。当我开始测试以这种方式编写的代码时，python 解释器立即开始崩溃，没有任何警告。

这是非常令人沮丧的地方:Python 崩溃了，因为 - 使用上面包含的链接中的类 - 我已将 sys.stdout/err 流分配给 QTextEdit 小部件； PyQt 小部件不能从应用程序线程以外的任何线程修改，并且由于对 stdout 和 stderr 的更新来 self 创建的辅助工作线程，因此它们违反了此规则。我已注释掉我重定向输出流的代码部分，果然，程序运行没有错误。

这让我回到了原点，让我陷入了困惑的境地；假设我继续在主线程中处理与 GUI 相关的操作，并在辅助线程中处理计算和更长的操作(我已经明白这是防止应用程序在用户触发事件时阻塞的最佳方法)，我怎么能将两个线程的 Stdout 和 Stderr 重定向到 QTextEdit 小部件？上面链接中的类在主线程中工作得很好，但是当更新来自第二个线程时，由于上述原因，杀死了 python。

Answer 1

首先，+1 用于实现线程不安全的许多堆栈溢出示例!

解决方案是使用线程安全对象(如 Python Queue.Queue)来调解信息的传输。我在下面附上了一些示例代码，它们将 stdout 重定向到 Python Queue。 Queue 被 QThread 读取，它通过 Qt 的信号/槽机制将内容发送到主线程(发出信号是线程安全的)。然后主线程将文本写入文本编辑。

希望这很清楚，如果不是，请随时提出问题!

编辑:请注意，提供的代码示例不能很好地清理 QThreads，因此当您退出时会打印出警告。我将把它留给你来扩展你的用例并清理线程

import sys
from Queue import Queue
from PyQt4.QtCore import *
from PyQt4.QtGui import *

# The new Stream Object which replaces the default stream associated with sys.stdout
# This object just puts data in a queue!
class WriteStream(object):
    def __init__(self,queue):
        self.queue = queue

    def write(self, text):
        self.queue.put(text)

# A QObject (to be run in a QThread) which sits waiting for data to come through a Queue.Queue().
# It blocks until data is available, and one it has got something from the queue, it sends
# it to the "MainThread" by emitting a Qt Signal 
class MyReceiver(QObject):
    mysignal = pyqtSignal(str)

    def __init__(self,queue,*args,**kwargs):
        QObject.__init__(self,*args,**kwargs)
        self.queue = queue

    @pyqtSlot()
    def run(self):
        while True:
            text = self.queue.get()
            self.mysignal.emit(text)

# An example QObject (to be run in a QThread) which outputs information with print
class LongRunningThing(QObject):
    @pyqtSlot()
    def run(self):
        for i in range(1000):
            print i

# An Example application QWidget containing the textedit to redirect stdout to
class MyApp(QWidget):
    def __init__(self,*args,**kwargs):
        QWidget.__init__(self,*args,**kwargs)

        self.layout = QVBoxLayout(self)
        self.textedit = QTextEdit()
        self.button = QPushButton('start long running thread')
        self.button.clicked.connect(self.start_thread)
        self.layout.addWidget(self.textedit)
        self.layout.addWidget(self.button)

    @pyqtSlot(str)
    def append_text(self,text):
        self.textedit.moveCursor(QTextCursor.End)
        self.textedit.insertPlainText( text )

    @pyqtSlot()
    def start_thread(self):
        self.thread = QThread()
        self.long_running_thing = LongRunningThing()
        self.long_running_thing.moveToThread(self.thread)
        self.thread.started.connect(self.long_running_thing.run)
        self.thread.start()

# Create Queue and redirect sys.stdout to this queue
queue = Queue()
sys.stdout = WriteStream(queue)

# Create QApplication and QWidget
qapp = QApplication(sys.argv)  
app = MyApp()
app.show()

# Create thread that will listen on the other end of the queue, and send the text to the textedit in our application
thread = QThread()
my_receiver = MyReceiver(queue)
my_receiver.mysignal.connect(app.append_text)
my_receiver.moveToThread(thread)
thread.started.connect(my_receiver.run)
thread.start()

qapp.exec_()