PYQT5中的QThreads:这是官方QThread文档的C++到Python的正确翻译吗？

Question

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

文档描述了两种基本方法:(1)worker-object方法和(2)QThread子类方法。
我在几篇文章中读到第二种方法不好，所以让我们集中讨论第一种方法。

编辑:
@ekhumoro给我指出了下面这篇有趣的文章：https://woboq.com/blog/qthread-you-were-noth-down-so-wurn.html。显然，这两种方法（1）和（2）各有其优点：

由于我确实需要在QApplication线程和新的QThread之间进行某种通信（我相信signal-slot是一种很好的通信方式），所以我将使用Worker-Object方法。

我已经复制粘贴了Worker-Object方法的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 &);
};

 

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):
我（通过一些文档）发现了这种结束应用程序的方法。第一个codeline结束WorkerThread（通过终止其事件循环）。第二个codeline结束mainthread（也通过终止其事件循环）。}

_{注意(5):
在Windows控制台中运行代码时，什么也没有发生（它只是挂起）。根据@pschill的建议（见下面他的评论），我添加了这个codeline以确保调用dowork()函数。}

 

将代码全局应用程序和app.exit()添加到handleResults(..)插槽可以修复挂起问题。但是背景到底发生了什么呢？这些代码是在扼杀工人线程吗？还是主QApplication线程？

有没有一种方法可以在不杀死主QApplication线程的情况下杀死辅助线程？

1.仍然不确定…

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

    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位}

Answer 1

您的Python示例应用程序需要以某种方式退出，否则它只是在控制器对象初始化后就坐在那里。

最简单的方法是将示例中的handleResults函数更改为：

@pyqtSlot(str)
def handleResults(self, param):
    print(param)
    global app
    app.exit()

希望能有所帮助。