QThread 没有完成

Question

我正在 PyQt5 的后台线程中构建带有套接字连接的 GUI 运行ning。除了 Qthread 从不发出完成信号外，一切都运行良好。也许这不是问题，我可以改变我的实现来解决它，但是一旦被移动的对象停止做任何事情，Qthread 将继续运行的预期行为是什么？

我是否应该在主线程中编写一个函数 class 以在完成线程后停止该线程，或者我是否可以将新内容移动到该线程而不产生任何后果？

class MyClass(PyQt5.QtWidgets.QMainWindow)
    def __init__(self, parent=None):

        # Setup thread for the socket control
        self.simulThread = PyQt5.QtCore.QThread()
        self.socketController = SocketController()
        self.socketController.moveToThread(self.simulThread)
        self.simulThread.started.connect(self.socketController.controlSocket)

        self.simulThread.finished.connect(self.deadThread)

        # Bind controls to events
        self.ui.buttonConnect.clicked.connect(self.simulThread.start)
        self.ui.buttonDisconnect.clicked.connect(lambda: self.socketController.stop())

   def deadThread(self, data):
       print ("THREAD IS DEAD.")

class SocketController(PyQt5.QtCore.QObject):
    finished       = PyQt5.QtCore.pyqtSignal()

    def __init__(self):
        super(SocketController, self).__init__()
        self.run = True;

    def controlSocket(self):
        #setup the socket

        while self.run:
            # do socket stuff
            time.sleep(1)

        #close the socket
        self.finished.emit()

    def stop(self):
        self.run = False;

Answer 1

A QThread 有自己的事件循环来处理信号。 controlSocket 方法会阻塞此事件循环，直到 self.run == False。但这永远不会发生，因为 self.run 仅在控制返回到事件循环时设置为 False，并且它可以处理运行 stop 方法的信号。

您可能想要重新设计您的线程，这样您就可以在调用 #do socket stuff每 1 秒编码一次。这样，控制返回到线程事件循环，它可以处理停止信号（将更改为停止 QTimer 再次触发）

Answer 2

好的，所以我找到了一个解决方案，但我真的不知道它是否正确。我没有将断开连接按钮映射到套接字停止函数，而是将其映射到 MyClass 中定义的函数，该函数调用我编写的名为 controlDisconnect 的新函数，该函数还明确告诉线程退出。

# The changed line
self.ui.buttonDisconnect.clicked.connect(self.controlDisconnect)

def controlDisconnect(self):
    self.socketController.stop()
    self.simulThread.quit()

虽然这是有效的（线程打印出指示它已死亡的消息），但我不确定它是否真的是好的做法。至少应该有一些代码来确保 socketController 在告诉线程退出之前实际上已经停止了。

Answer 3

答案实际上是 three_pineapples 和 OP 在他们的答案中发布的内容的组合：

正如 three_pineapples 所指出的，主要问题是 controlSocket()（在发出启动信号时被线程事件循环调用）不会 return 直到 stop()方法被调用。但是，在 OP 的设计中，只有当套接字线程可以处理事件时，Qt 才能调用 stop() 方法（因为这是通过事件循环调度 cross-thread 信号的方式）。当 controlSocket() 正忙于循环和休眠时，这是不可能的。
为了让线程退出，它的事件循环必须停止。

必须通过允许线程在循环期间处理事件或使用计时器而不是循环来解决第一个问题。处理事件显示在这段代码中，基于 OP 代码：

import time

from PyQt5.QtWidgets import QMainWindow, QWidget, QPushButton, QApplication, QHBoxLayout
from PyQt5.QtCore import QThread, QObject, pyqtSignal

class MyClass(QWidget):
    def __init__(self, parent=None):
        super().__init__()

        self.resize(250, 150)
        self.setWindowTitle('Simple')

        # Setup thread for the socket control
        self.socketController = SocketController()

        self.simulThread = QThread()
        self.socketController.moveToThread(self.simulThread)
        self.simulThread.started.connect(self.socketController.controlSocket)
        self.simulThread.finished.connect(self.deadThread)

        # Bind controls to events
        self.buttonConnect = QPushButton('connect')
        self.buttonConnect.clicked.connect(self.simulThread.start)

        self.buttonDisconnect = QPushButton('disconnect')
        self.buttonDisconnect.clicked.connect(self.socketController.stop)

        hbox = QHBoxLayout()
        hbox.addStretch(1)
        hbox.addWidget(self.buttonConnect)
        hbox.addWidget(self.buttonDisconnect)
        self.setLayout(hbox)

    def deadThread(self, data):
        print("THREAD IS DEAD.")


class SocketController(QObject):
    finished = pyqtSignal()

    def __init__(self):
        print('initialized')
        super().__init__()
        self.run = True

    def controlSocket(self):
        # setup the socket

        print('control socket starting')
        while self.run:
            # do socket stuff
            app.processEvents()
            print('control socket iterating')
            time.sleep(1)

        # close the socket
        self.finished.emit()
        print('control socket done')

    def stop(self):
        print('stop pending')
        self.run = False


app = QApplication([])
mw = MyClass()
mw.move(300, 300)
mw.show()
app.exec()

QTimer 稍微复杂一点，但想法是让 controlSocket() 只执行一次循环迭代，并通过 QTimer 重复调用它：

QTimer.singleShot(0, self.controlSocket)

和

def controlSocket(self):
    # do socket stuff, then:
    if self.run:
        QTimer.singleShot(1000, self.controlSocket)
    else:
        self.finished.emit()

以上任何一种方法都解决了第一个问题，并允许 SocketController 停止执行其 socket-related 工作。

第二个问题是，即使套接字控制器完成了它的工作，线程循环仍然是运行（两个循环是独立的）。要使事件循环退出，必须通过线程的 quit() 方法停止它。退出和停止应该一起完成：

class MyClass(QWidget):
    def __init__(self, parent=None):
        ...

        self.buttonDisconnect = QPushButton('disconnect')
        self.buttonDisconnect.clicked.connect(self.stop)

        hbox = QHBoxLayout()
        hbox.addStretch(1)
        hbox.addWidget(self.buttonConnect)
        hbox.addWidget(self.buttonDisconnect)
        self.setLayout(hbox)

    def stop(self):
        self.simulThread.quit()
        self.socketController.stop()

QThread 没有完成

QThread doesn't finish

python

python-3.x

pyqt

pyqt5