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

Question

堆栈溢出。我再次在迫切需要的时候来到你身边，在 精神错乱 的边缘摇摇欲坠。从标题可以明显看出，这个问题是我在这里看到的其他几个问题的结合。

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

最初，我发现以下堆栈溢出答案： http://codingdict.com/questions/160679

这完美地工作了，但有一个警告：如果在CPU处理相对较长的方法时多次更新stdout或stderr，则 当主线程返回到应用程序循环时 ，
所有更新同时显示 。不幸的是，我有几种方法可能需要20秒钟才能完成（与网络相关），因此应用程序将无响应-并且QTextEdit不会更新-直到完成。

为了解决此问题，
我将所有GUI处理都委派给了主线程，并派出了第二个线程来处理更长的联网操作，并使用pyqtSignals通知主线程工作何时完成并通过。返回结果。
当我开始测试以这种方式编写的代码时，python解释器立即崩溃，没有任何警告。

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

这使我回到第一位，并使我陷入混乱的境地。假设我继续在主线程中处理与GUI相关的操作，并在辅助线程中处理计算和较长的操作（我已经理解这是防止用户触发事件时阻止应用程序运行的最佳方法），从两个线程重定向Stdout和Stderr到QTextEdit小部件？上面链接中的类在主线程上工作正常，但由于第二个线程进行了更新，由于上述原因，它杀死了python。

Answer 1

首先，+ 1是为了实现许多关于堆栈溢出的示例的线程 安全性 ！

解决方案是使用线程安全对象（如Python
Queue.Queue）来中介信息的传递。我在下面附加了一些示例代码，这些示例代码重定向stdout到Python
Queue。这Queue是由a读取的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_()