PyQt5 动态运行同一个线程

Question

我正在使用 python 3.7 和 pyqt5

我想要做的是多次使用不同的线程运行相同的 QObject。

这是我的主要内容

from PyQt5.QtCore import *
from PyQt5.QtWidgets import *
import threading
import sys
from Worker_Starting import Worker_Starting


class Main(QMainWindow):
    def __init__(self) :
        super().__init__()
        self.setupUI()
        self.initSignal()

    def setupUI(self):
        self.resize(400, 400)
        self.pushButton = QPushButton("Start", self)
        self.pushButton_2 = QPushButton("Stop", self)
        self.pushButton.move(0,0)
        self.pushButton_2.move(120,0)


    def initSignal(self) :
        self.pushButton.clicked.connect(self.Start)
        self.pushButton_2.clicked.connect(self.Stop)

    @pyqtSlot()
    def Start(self) :
        for i in range(3) :  
            print('main', threading.get_ident())
            input = ["userID", "userNAME"]

            self.my_thread = QThread()
            self.my_worker = Worker_Starting(passing_list=input)
            self.my_worker.moveToThread(self.my_thread)
            self.my_thread.started.connect(self.my_worker.my_fn)
            self.my_thread.start()
            time.sleep(3)


    @pyqtSlot()
    def Stop(self) :
        pass

if __name__ == "__main__":
    app = QApplication(sys.argv)
    window = Main()
    window.show()
    app.exec_()

还有我的 Qobject

from PyQt5 import QtCore
from PyQt5.QtCore import *
import time
import threading

class Worker_Starting(QObject):
    def __init__(self, passing_list, parent=None):
        QtCore.QThread.__init__(self, parent=parent)
        self.userid = passing_list[0]
        self.username = passing_list[1]

    def my_fn(self):
        print(self.username, threading.get_ident())
        for i in range(10) :
            Now = time.strftime("%Y/%m/%d %H:%M:%S")
            print(str(i) + " : " + self.username + "  running" + " : " + Now)
            time.sleep(0.5)

我把for i in range(3):放在def start(self):下面

因为在我的实际主脚本中，其他线程多次向def start(self): 发出输入。

如果我只发出一次，def start(self): 可以正常工作。 但是当我发射几次时，它就会崩溃。 因为我必须多次发射，我需要my_thread 才能同时连续工作

有没有办法将相同的 Qobject 设置到不同的线程？

以及如何知道或设置线程ID。

以及如何通过线程 id 停止线程。

*我已经尝试过 QRunnable，我现在可以使用多线程了。但我必须不断地向我的主发出信号。据我所知 QRunnable 不适合自定义信号。

Answer 1

问题是您不断地通过覆盖现有线程来创建新线程，这会导致以前的线程在完成之前被垃圾收集，从而导致崩溃。

如果你想并发执行同一个“worker”函数，你不能为多个线程使用一个对象，因为你应该每次都使用moveToThread，这是不可能的。

解决方案是改用QRunnable，在其run()方法中实现函数，并调用QThreadPool来运行它。

class Worker_Starting(QRunnable):
    def __init__(self, passing_list):
        QRunnable.__init__(self)
        self.setAutoDelete(False)
        self.userid = passing_list[0]
        self.username = passing_list[1]

    def run(self):
        print(self.username, threading.get_ident())
        for i in range(10) :
            Now = time.strftime("%Y/%m/%d %H:%M:%S")
            print(str(i) + " : " + self.username + "  running" + " : " + Now)
            time.sleep(0.5)


class Main(QMainWindow):
    def __init__(self) :
        super().__init__()
        self.setupUI()
        self.initSignal()
        self.worker = None

    # ...

    def Start(self) :
        if not self.worker:
            input = ["userID", "userNAME"]
            self.worker = Worker_Starting(passing_list=input)
        for i in range(3):
            print('main', threading.get_ident())
            QThreadPool.globalInstance().start(self.worker)

请记住，您应该不在主 Qt 线程中使用阻塞函数（这就是我从 Start() 中删除 time.sleep(3) 的原因）。如果您想定期多次启动该功能，请使用 QTimer：

        interval = 3000 # interval is in milliseconds
        for i in range(3):
            print('main', threading.get_ident())
            QTimer.singleShot(interval * i, lambda:
                QThreadPool.globalInstance().start(self.worker))

请注意，pyqtSlot() 装饰器通常仅用于特殊情况和高级实现，因此您应该删除它。另请注意，只有类和常量的名称应大写，而函数、变量和属性应小写（首选start 和stop，而不是Start 和Stop）。