使用QObject从Python线程发出信号

Question

我想知道与QThread相比,从QObject中的常规python线程发出信号会产生什么后果.

请参阅以下课程:

class MyObject(QtCore.QObject):

    def __init__(self):
        super().__init__()

    sig = pyqtSignal()

    def start(self):
        self._thread = Thread(target=self.run)
        self._thread.start()

    def run(self):
        self.sig.emit()
        # Do something

现在,假设在GUI线程中,我有:

def __init__(self):
    self.obj = MyObject()
    self.obj.sig.connect(self.slot)
    self.obj.start()

def slot(self):
    # Do something

在slot当所述信号被发射确实执行.但是,我想知道该slot方法将在哪个线程中执行？如果我使用QThread而不是python线程,它会有什么不同MyObject吗？

我正在使用PyQt5和Python 3.

Answer 1

默认情况下,Qt 会在跨线程发出信号时自动对信号进行排队.为此,它将信号参数序列化,然后将事件发布到接收线程的事件队列,最终将执行任何连接的槽.因此,以这种方式发出的信号保证是线程安全的.

关于外部线程,Qt文档声明如下:

注意:Qt的线程类是使用本机线程API实现的; 例如,Win32和pthreads.因此,它们可以与相同本机API的线程一起使用.

通常,如果文档声明Qt API是线程安全的,那么该保证适用于使用相同本机库创建的所有线程 - 而不仅仅是由Qt本身创建的线程.这意味着它也可以放心明确张贴使用这种线程安全的API为事件给其他线程postEvent()和invoke().

因此,只要Python和Qt都使用相同的底层本机线程库,使用threading.Thread和QThread发出跨线程信号之间就没有真正的区别.这表明在PyQt应用程序中更喜欢使用的一个可能原因是可移植性,因为没有混合不兼容的线程实现的危险.但是,鉴于Python和Qt都是故意设计为跨平台的,因此在实践中出现这个问题的可能性极小.QThread

至于slot将要执行哪个线程的问题- 对于Python和Qt,它将在主线程中.相反,该run方法将在工作线程中执行.在Qt应用程序中执行多线程时,这是一个非常重要的考虑因素,因为在主线程之外执行gui操作是不安全的.使用信号允许您在工作线程和gui之间进行安全通信,因为连接到工作者发出的信号的插槽将在主线程中调用,允许您在必要时更新gui.

下面是一个简单的脚本,显示了调用每个方法的线程:

import sys, time, threading
from PyQt5 import QtCore, QtWidgets

def thread_info(msg):
    print(msg, int(QtCore.QThread.currentThreadId()),
          threading.current_thread().name)

class PyThreadObject(QtCore.QObject):
    sig = QtCore.pyqtSignal()

    def start(self):
        self._thread = threading.Thread(target=self.run)
        self._thread.start()

    def run(self):
        time.sleep(1)
        thread_info('py:run')
        self.sig.emit()

class QtThreadObject(QtCore.QThread):
    sig = QtCore.pyqtSignal()

    def run(self):
        time.sleep(1)
        thread_info('qt:run')
        self.sig.emit()

class Window(QtWidgets.QWidget):
    def __init__(self):
        super(Window, self).__init__()
        self.pyobj = PyThreadObject()
        self.pyobj.sig.connect(self.pyslot)
        self.pyobj.start()
        self.qtobj = QtThreadObject()
        self.qtobj.sig.connect(self.qtslot)
        self.qtobj.start()

    def pyslot(self):
        thread_info('py:slot')

    def qtslot(self):
        thread_info('qt:slot')

if __name__ == '__main__':

    app = QtWidgets.QApplication(sys.argv)
    window = Window()
    window.setGeometry(600, 100, 300, 200)
    window.show()
    thread_info('main')
    sys.exit(app.exec_())

输出:

main 140300376593728 MainThread
py:run 140299947104000 Thread-1
py:slot 140300376593728 MainThread
qt:run 140299871450880 Dummy-2
qt:slot 140300376593728 MainThread