python - 如何在 PyQt 中使用 QThreads 双向设置信号和槽？

Question

这是基于 ekhumoro 的回答的后续问题 here和 here .

<小时/>

我想明白，当使用pyqtSlot正确定义插槽并将其分配给QThread(例如使用moveToThread())时，它将在此 QThread 中执行，而不是在调用者中执行。此外，还需要与Qt.QueuedConnection或Qt.AutoConnection建立连接。

我编写了代码来测试这一点。我的目标是实现像这样非常简单的事情:
带有按钮的 GUI，可启动一些耗时的工作并返回结果以显示在 GUI 中。

from PyQt5.Qt import *

class MainWindow(QMainWindow):
    change_text = pyqtSignal(str)

    def __init__(self):
        super().__init__()
        self.button = QPushButton('Push me!', self)
        self.setCentralWidget(self.button)

        print('main running in:', QThread.currentThread())
        thread = Thread(change_text, self)
        thread.start()
        self.button.clicked.connect( thread.do_something_slow, Qt.QueuedConnection)
        self.change_text.connect(self.display_changes, Qt.QueuedConnection)

    @pyqtSlot(str)
    def display_changes( self, text ):
        self.button.setText(text)

class Thread(QThread):
    def __init__(self, signal_to_emit, parent):
        super().__init__(parent)
        self.signal_to_emit = signal_to_emit
        #self.moveToThread(self) #doesn't help

    @pyqtSlot()
    def do_something_slow( self ):
        print('Slot doing stuff in:', QThread.currentThread())
        import time
        time.sleep(5)
        self.signal_to_emit.emit('I did something')

if __name__ == '__main__':
    app = QApplication([])
    main = MainWindow()
    main.show()
    app.exec()

但是.. gui 被阻塞并且插槽在主线程中被调用。
我缺少什么？必须是一些小东西(我希望)。

Answer 1

问题是你混淆了 QThread是Qt线程，即Qt创建的新线程，但是不是，QThread是一个处理 native 线程的类，仅 run()方法正在另一个线程上运行，其他方法位于 QThread 所在的线程中生命，这是一个 QObject ,

QObject 存在于哪个线程中？

其中有 QObject 的线程生命是父线程的生命，如果它没有父线程，它将是创建它的线程。另一方面，QObject可以使用 moveToThread() 移动到另一个线程，并且它的所有子项也会移动。仅moveToThread()如果 QObject 则可以使用没有父级，否则会失败。

<小时/>

使用方法QThread就是创建一个继承于 QThread 的类并重写 run 方法并调用 start()以便它开始运行 run() ，在 run()方法将完成繁重的任务，但在您的情况下不能使用这种形式，因为任务不会连续执行。比繁重任务更好的选择是 QObject 的一部分，以及QObject将其移动到另一个线程。

class MainWindow(QMainWindow):
    change_text = pyqtSignal(str)

    def __init__(self):
        super().__init__()
        self.button = QPushButton('Push me!', self)
        self.setCentralWidget(self.button)
        print('main running in:', QThread.currentThread())
        # A Worker without a parent is created 
        # so that it can be moved to another thread.
        self.worker = Worker(self.change_text)
        thread = QThread(self) 
        self.worker.moveToThread(thread)
        thread.start()
        # All methods of self.worker are now executed in another thread.
        self.button.clicked.connect(self.worker.do_something_slow)
        self.change_text.connect(self.display_changes)

    @pyqtSlot(str)
    def display_changes( self, text ):
        self.button.setText(text)


class Worker(QObject):
    def __init__(self, signal_to_emit, parent=None):
        super().__init__(parent)
        self.signal_to_emit = signal_to_emit

    @pyqtSlot()
    def do_something_slow( self ):
        print('Slot doing stuff in:', QThread.currentThread())
        import time
        time.sleep(5)
        self.signal_to_emit.emit('I did something')

另一方面，无需指示连接类型，因为默认情况下它是 Qt::AutoConnection ，这种类型的连接在运行时决定是否使用 Qt::DirectConnection如果接收器与发射信号位于同一根电线中，否则 Qt::QueuedConnection用来。正如您所意识到的，Worker 没有父级，因此要使其具有与类相同的生命周期，它必须是它的一个属性，否则它将是一个被消除的局部变量。另一方面，请注意 QThread接收父窗口而不是 MainWindow，因此 QThread将驻留在 GUI 线程中，但它处理辅助线程。

<小时/>

采用 Worker 概念，最好是 Change_text 信号不再属于 GUI，而是属于能够更好地解耦对象的 Worker。

class MainWindow(QMainWindow):
    def __init__(self):
        super().__init__()
        self.button = QPushButton('Push me!', self)
        self.setCentralWidget(self.button)

        print('main running in:', QThread.currentThread())
        self.worker = Worker()
        thread = QThread(self)
        self.worker.moveToThread(thread)
        thread.start()
        self.button.clicked.connect(self.worker.do_something_slow)
        self.worker.change_text.connect(self.display_changes)

    @pyqtSlot(str)
    def display_changes( self, text ):
        self.button.setText(text)

class Worker(QObject):
    change_text = pyqtSignal(str)

    @pyqtSlot()
    def do_something_slow( self ):
        print('Slot doing stuff in:', QThread.currentThread())
        import time
        time.sleep(5)
        self.change_text.emit('I did something')