qthread.fined Signal IS不发出工人完成后发出

Question

我有以下代码：

import time

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


class Worker(QObject):

    def run(self):
        time.sleep(1)
        print("Worker is finished")


class MainWindow(QWidget):

    def __init__(self):
        super().__init__()
        self.show()

        self.thread = QThread()
        self.worker = Worker()
        self.worker.moveToThread(self.thread)
        self.thread.started.connect(self.worker.run)
        self.thread.finished.connect(self.on_thread_finished)
        self.thread.start()

    def on_thread_finished(self):
        print("Thread finished")
        self.thread.deleteLater()


if __name__ == "__main__":
    app = QApplication([])
    window = MainWindow()
    app.exec_()

运行它，它显示窗口，打印工作者完成，仅此而已。那很奇怪。恕我直言，工人完成后，线程也应完成，这意味着应调用on_thread_fined方法，并且应打印thread完成。但不是。为什么？

Answer 1

当您使用movetothread而不是重新完成，该线程将启动自己的事件环，该循环将等到明确调用退出/退出。仅在事件环停止后发出完成的信号（和/或一次run返回）。处理这种情况的通常方法是从工人发出自定义信号，并将其连接到线程的Quit插槽。 （NB：跨线程信号插槽连接可以保证是线程安全的）。

因此，您的示例将按照预期进行以下更改，可以按照预期工作：

class Worker(QObject):
    finished = QtCore.pyqtSignal()

    def run(self):
        time.sleep(1)
        print("Worker is finished")
        self.finished.emit()


class MainWindow(QWidget):    
    def __init__(self):
        ...
        self.worker.moveToThread(self.thread)
        self.worker.finished.connect(self.thread.quit)

Answer 2

工人完成后，线程也应完成

这不是其工作原理。您的Worker :: Run方法通过常规signal> signal>/code>/插槽>插槽机制，将方法调用为插槽 Qthread将继续按照正常方式处理事件。

如果要终止qthread当wrorker :: Run完成时，您需要告诉它要明确地做到这一点……

import time

from PyQt5.QtCore import Qt, QThread, QObject
from PyQt5.QtWidgets import QWidget, QApplication


class Worker(QObject):

    # Constructor accepts the QThread as a parameter and stashes it
    # for later use.
    def __init__(self, thread):
        super(Worker, self).__init__()
        self.m_thread = thread
    def run(self):
        time.sleep(1)
        print("Worker is finished")

        # We're done so ask the `QThread` to terminate.
        if self.m_thread:
            self.m_thread.quit()


class MainWindow(QWidget):

    def __init__(self):
        super().__init__()
        self.show()

        self.thread = QThread()

        # Pass the QThread to the Worker's ctor.
        self.worker = Worker(self.thread)
        self.worker.moveToThread(self.thread)
        self.thread.started.connect(self.worker.run)
        self.thread.finished.connect(self.on_thread_finished)
        self.thread.start()

    def on_thread_finished(self):
        print("Thread finished")
        self.thread.deleteLater()


if __name__ == "__main__":
    app = QApplication([])
    window = MainWindow()
    app.exec_()

非常“非常''，但它传达了这个想法。

Springs的一种更简单的替代方法是简单地使用Qthread :: CusthRead（），在这种情况下，您的worker :: Run方法>方法>方法变为...

class Worker(QObject):
    def run(self):
        time.sleep(1)
        print("Worker is finished")

        # We're done so ask the `QThread` to terminate.
        QThread.currentThread().quit()