Pyqt5 两个QThread通信使用信号和槽问题

Question

我正在尝试将 pyqt qthread 用于多线程程序。

在代码中，有两个不同的工人实例。我尝试使用信号和插槽进行数据共享。但似乎信号被阻塞，直到其中一个 qthread 完成。

这是代码。

from PyQt5.QtCore import QCoreApplication,QThread, QObject, pyqtSignal, pyqtSlot
import time
import sys

class Worker(QObject):
    finished = pyqtSignal()
    intReady = pyqtSignal(int)

    @pyqtSlot()
    def work(self):  # A slot takes no params
        for i in range(1, 10):
            time.sleep(1)
            self.intReady.emit(i)

        self.finished.emit()


class Worker2(QObject):
    finished = pyqtSignal()
    intReady = pyqtSignal(int)

    @pyqtSlot()
    def work(self):  # A slot takes no params
        for i in range(1, 10):
            time.sleep(1)
            self.intReady.emit(i)

        self.finished.emit()

    @pyqtSlot(int)
    def revsignal(self, val):
        print("hello rev a signal"+str(val))

def updateLabel(val):
    print("updateLable "+str(val))

app = QCoreApplication(sys.argv)
# 1 - create Worker and Thread inside the Form
worker = Worker()  # no parent!
thread = QThread()  # no parent!

worker2 = Worker2()
thread2 = QThread()

worker.intReady.connect(updateLabel)
worker.intReady.connect(worker2.revsignal)

worker.moveToThread(thread)
worker.finished.connect(thread.quit)
thread.started.connect(worker.work)
# self.thread.finished.connect(app.exit)


worker2.moveToThread(thread2)
worker2.finished.connect(thread2.quit)
thread2.started.connect(worker2.work)

thread2.finished.connect(app.exit)



thread2.start()
print("after thread2 start")
thread.start()
print("after thread1 start.")



sys.exit(app.exec_())

输出在这里

after thread2 start
after thread1 start.
updateLable 1
updateLable 2
updateLable 3
updateLable 4
updateLable 5
updateLable 6
updateLable 7
updateLable 8
updateLable 9
hello rev a signal1
hello rev a signal2
hello rev a signal3
hello rev a signal4
hello rev a signal5
hello rev a signal6
hello rev a signal7
hello rev a signal8
hello rev a signal9

Process finished with exit code 0

不知道为什么work1发出信号后worker2线程收不到信号。直到 work1 线程结束。

非常感谢任何帮助！

Answer 1

首先，所有插槽都应该是继承自 QObject 的 class 的成员。所以像这样制作一个class

class Manager(QObject):
    @pyqtSlot(int)
    def updateLabel(self, val):
        print("updateLable "+str(val))
manager = Manager()

接下来，根据文档 here，还有一个附加参数可以传递给 connect 以控制跨线程信号处理的行为。您需要更改三行。

from PyQt5.QtCore import QCoreApplication, QThread, QObject, pyqtSignal, pyqtSlot, Qt

获取 Qt 命名空间，

worker.intReady.connect(manager.updateLabel, type=Qt.DirectConnection)
worker.intReady.connect(worker2.revsignal, type=Qt.DirectConnection)

设置连接类型。

Pyqt5 两个QThread通信使用信号和槽问题

Pyqt5 Two QThread communicate use signal and slot issue

pyqt

qthread