pyqt使用消息队列传递数据

PyQt中可以使用QThread和QQueue来实现消息队列传递数据。

首先，创建一个QObject子类来处理数据。这个子类需要继承QThread和QQueue，并重写run()方法来处理数据。

from PyQt5.QtCore import QThread, QQueue, pyqtSignal, pyqtSlot, QObject

class DataReceiver(QThread, QQueue):
    data_received = pyqtSignal(str)

    def __init__(self):
        QThread.__init__(self)
        QQueue.__init__(self)
        self.running = True

    def stop(self):
        self.running = False

    def run(self):
        while self.running:
            if not self.isEmpty():
                data = self.dequeue()
                self.data_received.emit(data)

然后，在主线程中创建DataReceiver对象，并连接其data_received信号到槽函数，以接收处理后的数据。

from PyQt5.QtWidgets import QApplication, QMainWindow
from PyQt5.QtCore import pyqtSlot

class MainWindow(QMainWindow):
    def __init__(self):
        QMainWindow.__init__(self)
        self.receiver = DataReceiver()
        self.receiver.data_received.connect(self.handle_data_received)
        self.receiver.start()

    @pyqtSlot(str)
    def handle_data_received(self, data):
        print(data)

最后，将需要传递的数据放入DataReceiver的队列中即可。

self.receiver.enqueue("Hello, World!")

这样，就可以通过消息队列在不同线程中传递数据了。