使用 moveToThread 在 PyQt5 中启动 QThread。一个线程无法正常启动

Nin*_*nga 2 python multithreading pyqt qthread pyqt5

我在下面的(半)工作示例中有 4 个工作线程。我只能让前三个工作线程工作。如何让第四个线程运行?

print(QThread.idealThreadCount())在我的笔记本电脑上返回“8”。

我可以重新排序代码以使 3 个工作线程的任意组合运行。

from PyQt5.QtCore import QThread, QObject
from PyQt5.QtWidgets import QWidget
import sys
from PyQt5.QtWidgets import QApplication
import time

class A(QObject):
    def run(self):
        while 1:
            print('A', time.ctime())
            time.sleep(1)
class B(QObject):
    def run(self):
        while 1:
            print('B', time.ctime())
            time.sleep(1)
class C(QObject):
    def run(self):
        while 1:
            print('C', time.ctime())
            time.sleep(1)
class D(QObject):
    def run(self):
        while 1:
            print('D', time.ctime())
            time.sleep(1)

class window1(QWidget):
    def __init__ (self, parent = None):
        super().__init__ () #parent widget
        print(QThread.idealThreadCount())

        self.thread1 = QThread()
        obj1 = A()
        obj1.moveToThread(self.thread1)
        self.thread1.started.connect(obj1.run)
        self.thread1.start()

        self.thread2 = QThread()
        obj2 = B()
        obj2.moveToThread(self.thread2)
        self.thread2.started.connect(obj2.run) 
        self.thread2.start()

        self.thread3 = QThread()
        obj3 = C()
        obj3.moveToThread(self.thread3)
        self.thread3.started.connect(obj3.run)
        self.thread3.start()

        self.thread4 = QThread()
        obj4 = D()
        obj4.moveToThread(self.thread4)
        self.thread4.started.connect(obj4.run)
        self.thread4.start()

app = QApplication(sys.argv) 
w = window1()
w.show()
sys.exit(app.exec_())
Run Code Online (Sandbox Code Playgroud)

thr*_*les 6

您没有存储对 等的引用obj1obj2由于它们没有父级(使用时需要moveToThread),因此它们将在方法结束时被垃圾收集__init__。您time.sleep(1)添加的只是延迟方法的结束__init__和垃圾收集。

如果您存储对对象的引用(例如self.obj1 = ...),那么所有线程都应该正确运行。