python - Pyqt5 中的 QThreads：这是官方 QThread 文档的正确 C++ 到 Python 的翻译吗？

问题描述

关于如何实例化和使用 a 的官方文档QThread可以在这里找到：http: //doc.qt.io/qt-5/qthread.html

该文档描述了两种基本方法：（1）工作对象方法和（2）QThread子类方法。
我在几篇文章中读到第二种方法不好，所以让我们关注第一种。

编辑：
@ekhumoro 向我指出了以下有趣的文章：https ://woboq.com/blog/qthread-you-were-not-doing-so-wrong.html 。显然，两种方法（1）和（2）都有各自的优点：

根据经验：
如果你真的不需要线程中的事件循环，你应该子类化。

如果您需要一个事件循环并在线程中处理信号和槽，您可能不需要子类化。

由于我确实需要 QApplication 线程和新 QThread 之间的某种通信（而且我相信信号槽是一种很好的通信方式），我将使用worker-object 方法。

1. C++ 中的工作对象方法

我已经复制粘贴了工作对象方法的 C++ 代码（来自官方 Qt5 文档，请参阅http://doc.qt.io/qt-5/qthread.html）：

class Worker : public QObject
{
    Q_OBJECT

public slots:
    void doWork(const QString &parameter) {
        QString result;
        /* ... here is the expensive or blocking operation ... */
        emit resultReady(result);
    }

signals:
    void resultReady(const QString &result);
};

class Controller : public QObject
{
    Q_OBJECT
    QThread workerThread;
public:
    Controller() {
        Worker *worker = new Worker;
        worker->moveToThread(&workerThread);
        connect(&workerThread, &QThread::finished, worker, &QObject::deleteLater);
        connect(this, &Controller::operate, worker, &Worker::doWork);
        connect(worker, &Worker::resultReady, this, &Controller::handleResults);
        workerThread.start();
    }
    ~Controller() {
        workerThread.quit();
        workerThread.wait();
    }
public slots:
    void handleResults(const QString &);
signals:
    void operate(const QString &);
};

2. Python 中的工作对象方法

我努力将给定的 C++ 代码翻译成 Python。如果你安装了 Python 3.6 和 PyQt5，你可以简单地复制粘贴这段代码并在你的机器上运行它。它应该工作。

import sys
from PyQt5.QtWidgets import *
from PyQt5.QtCore import *
from PyQt5.QtGui import *

class Worker(QObject):

    resultReady = pyqtSignal(str)

    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)

    @pyqtSlot(str)
    def doWork(self, param):
        result = "hello world"
        print("foo bar")
        # ...here is the expensive or blocking operation... #
        self.resultReady.emit(result)


class Controller(QObject):

    operate = pyqtSignal(str)

    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)

        # 1. Create 'workerThread' and 'worker' objects
        # ----------------------------------------------
        self.workerThread = QThread()
        self.worker = Worker()          # <- SEE NOTE(1)
        self.worker.moveToThread(self.workerThread)

        # 2. Connect all relevant signals
        # --------------------------------
        self.workerThread.finished.connect(self.worker.deleteLater)
        self.workerThread.finished.connect(lambda: print("workerThread finished."))  # <- SEE NOTE(2)
        self.operate.connect(self.worker.doWork)
        self.worker.resultReady.connect(self.handleResults)

        # 3. Start the thread
        # --------------------
        self.workerThread.start()

    def __del__(self):
        self.workerThread.quit()
        self.workerThread.wait()

    @pyqtSlot(str)
    def handleResults(self, param):
        print(param)
        # One way to end application
        # ---------------------------
        # global app      # <- SEE
        # app.exit()      #     NOTE(3)

        # Another way to end application
        # -------------------------------
        self.workerThread.quit()   # <- SEE NOTE(4)
        self.thread().quit()


if __name__ == '__main__':
    app = QCoreApplication([])
    controller = Controller()
    controller.operate.emit("foo")      # <- SEE NOTE(5)
    sys.exit(app.exec_())

_{注意（1）：

最初我worker在构造函数中将变量实现为局部变量。我实际上是在将 C++ 示例翻译成 Python，并且这个变量也是 C++ 示例中的局部变量。

正如您在@pschill 的评论中看到的那样，这个局部变量被垃圾收集了，因此我无法让线程运行。进行更改后，我得到了预期的输出。}

_{注意（2）：

我添加了这一行以准确知道何时workerThread完成。}

_{注意（3）：

显然我需要将这两个代码行添加global app到app.exit()插槽handleResults(..)中。谢谢@Matic 指出这一点！}

_{注意（4）：

我（通过一些文档）发现了这种结束应用程序的方法。第一个代码行结束workerThread（通过终止其事件循环）。第二个代码行结束mainThread（也通过终止其事件循环）。}

_{注意 (5)：

在 Windows 控制台中运行代码时，什么也没发生（它只是挂起）。根据@pschill 的建议（请参阅下面的评论），我添加了此代码行以确保doWork()调用该函数。}

3. 我的问题

首先，我想知道我从 C++ 到 Python 的翻译是否正确。请告诉我我在哪里犯了错误（如果你发现任何错误）。
将代码行添加到插槽global app中可以解决挂起问题。但是背景究竟发生了什么？这些代码行是否会杀死工作线程？还是主 QApplication 线程？app.exit()handleResults(..)
有没有办法在不杀死主 QApplication 线程的情况下杀死工作线程？

4.一些答案

1.还是不确定..

2.我相信app.exit()杀死主线程，然后杀死工作线程，因为它是守护进程类型的。我发现工作线程是deamonprint(threading.current_thread())类型的，因为我在doWork(..)函数中插入了代码行。它打印了<_DummyThread(Dummy-1, started daemon 9812)>。当程序退出时，所有守护线程都会自动终止。

3. 是的，我找到了方法！该QThread::quit()功能是您的朋友。官方文档是这样说的：

voidQThread::quit()
告诉线程的事件循环以返回码 0（成功）退出。相当于调用QThread::exit(0)。
如果线程没有事件循环，则此函数不执行任何操作。
_{[ http://doc.qt.io/qt-5/qthread.html#quit]}

所以我的函数handleResults(..)现在看起来像这样：

    @pyqtSlot(str)
    def handleResults(self, param):
        print(param)
        self.workerThread.quit()  # Kill the worker thread
        self.thread().quit()      # Kill the main thread

我通过在以下构造函数中插入这一行来检查工作线程的终止Controller(..)：

    self.workerThread.finished.connect(lambda: print("workerThread finished."))

我确实按预期打印了该行。我还尝试以类似的方式检查主线程的终止：

    self.thread().finished.connect(lambda: print("mainThread finished."))

不幸的是，这条线没有打印出来。为什么？

_{在此我提供我当前的系统设置：

    > Qt5 ( QT_VERSION_STR= 5.10.1)

    > PyQt5 ( PYQT_VERSION_STR= 5.10.1)

    > Python 3.6.3

    > Windows 10, 64-bit}

标签： pythonpyqtqt5pyqt5qthread