PyQt 跨线程信号传递

Question

我一直在使用PyQt和跨线程的信号/槽。这里有一个我找不到错误的情况:

我有一个类(MultipleProcessLauncher)，它能够在单独的线程中启动多个进程。我捕获每个进程的标准输出并将这些消息发送到一个单一的队列中，该队列由另一个线程(OutputWorker)读取，最后这个线程应该发出一个 onNewMessage 信号(我认为它没有)，在主类中捕获，但回调函数从未被调用。

• 进程线程填充队列与消息
• 读取线程捕获所有这些消息(我可以在 while 循环中使用 print(item) 打印它们)

但是: - 读取线程的信号似乎没有发出任何东西，因此主线程的回调函数从未被调用...

非常感谢您的帮助，我认为我在跨线程信号方面缺少了一些东西...

class OutputWorker(QObject):
    onNewMessage = pyqtSignal(['QString'])

    def __init__(self, queue, parent=None):
        super(OutputWorker, self).__init__(parent)
        self.queue = queue

    def work(self):
        while True:
            item = self.queue.get()
            self.onNewMessage.emit(item)
            self.queue.task_done()

class MultipleProcessLauncher(QObject):
    commandEvent = pyqtSignal(['QString'])

    def __init__(self, parent=None):
        super(MultipleProcessLauncher, self).__init__(parent)

        self.messaging_queue = Queue()

        # Start reading message
        self.reading_thread = QThread()

        self.worker = OutputWorker(self.messaging_queue)
        self.worker.moveToThread(self.reading_thread)
        self.worker.onNewMessage.connect(self.command_event)

        self.reading_thread.started.connect(self.worker.work)
        self.reading_thread.start()

    def execute(self, command):
        p = subprocess.Popen(command, stdout=subprocess.PIPE)
        t = Thread(target=self.enqueue, args=(p.stdout, self.messaging_queue))
        t.daemon = True
        t.start()

    def enqueue(self, stdout, queue):
        for line in iter(stdout.readline, b''):
            queue.put(line.decode())
        stdout.close()

    def command_event(self, event):
        # This point is never reached
        print('message received')

if __name__ == '__main__':
    manager = MultipleProcessLauncher()
    manager.execute('ipconfig')

    time.sleep(100)

- And0rian

---

我认为item不会是一个QString。你可能需要更新你的信号定义为pyqtSignal(str)或类似的内容。虽然我不确定这是否是问题的原因。 - three_pineapples

如果我将QString更改为str，甚至在我的信号和槽上不放置任何参数，它都无法工作。 - And0rian

Answer 1

Qt的跨线程信号基于事件循环，因此您需要执行QApplication以便有一个主事件循环来处理来自其他线程的信号。例如：

if __name__ == '__main__':
    app = QApplication([])
    manager = MultipleProcessLauncher()
    manager.execute('ipconfig')
    MAX_WAIT_MSEC = 100 * 1000  # 100 seconds
    QTimer.singleShot(MAX_WAIT_MSEC, app.quit) 
    app.exec()

在您的实际应用程序中，您可能会基于用户输入执行管理器，因此执行将位于插槽中，并且不需要退出等操作，但您已经了解了这个想法。

- Oliver