PyQt, QThread, GIL, GUI

Question

我有一段使用Python编写的GUI和程序逻辑。我经常通过调用urllib.requests（等等）从Web请求信息，但这会导致GUI不响应。虽然这些调用被包装在QThread中，但我认为这是由于GIL引起的。但是，当我无法使代码异步工作时，我该如何在PyQt应用程序中使用QThread？在PyQt中，它的用途是什么？

-- 代码 -- qtthreaddecorator.py:

from PyQt4 import QtCore

class Worker(QtCore.QThread):
    def __init__(self, thread_name, finished_slot, function, *args, **kwargs):
        QtCore.QThread.__init__(self)

        self._thread_name = thread_name
        self._function = function
        self._args = args
        self._kwargs = kwargs

        self._finished_slot = finished_slot

    def run(self):
        self._function(*self._args, **self._kwargs)

        self._finished_slot()

        return

def qt_thread_decorator(slot):
    def decorator(function):
        def wrapper(*args, **kwargs):
            worker = Worker(function.__name__, slot, function, *args, **kwargs)
            worker.start()

            return
        return wrapper
    return decorator

我正在使用它的地方：

这个地方与IT技术有关。

import qtthreaddecorator

class MainWindow(QtGui.QMainWindow, form_class):

def __init__(self, parent=None):
    QtGui.QMainWindow.__init__(self, parent)
    self.setupUi(self)

    self.init()

def init(self):
    @qtthreaddecorator.qt_thread_decorator(self._fill_servers)
    def _get_servers():
        self._get_my_servers()
    @qtthreaddecorator.qt_thread_decorator(self._fill_user_info)
    def _get_user_info():
        self._get_user_info()

    _get_servers()
    _get_user_info()

在我的情况下，_get_servers() 和 _get_user_info() 是按顺序调用的，但我希望它们可以并发执行。

- Victor Polevoy

---

你是否正确地启动了线程，例如使用 worker_thread.start()？因为如果你使用 worker_thread.run()，它会运行，但不会在另一个线程中运行。 - Fenikso

准确地说是 worker_thread.start()。等一下，我要发布代码。 - Victor Polevoy

我同意@Fenikso的观点，这绝对是装饰器的有趣用法。我认为你的问题可能源于wrapper函数没有返回worker，因此它在该函数之外不存在。 - user3419537

我尝试从包装器中返回worker和True，但没有效果。 - Victor Polevoy

仅仅从wrapper中返回是不够的。最终，你需要让worker存在于你装饰的函数之外，否则当这些函数返回时，你会遇到同样的问题。我认为你使用装饰器使事情变得过于复杂了。 - user3419537

Answer 1

我认为你在使用装饰器时过于复杂了。你可以轻松地使用大约3-4行的设置代码将代码包装在新线程中。此外，我认为你不应该直接从另一个线程调用已完成的插槽。你应该使用连接的信号来激活它。

import sys
from time import sleep
from PyQt5.QtCore import *
from PyQt5.QtWidgets import *

class Signals(QObject):
    update = pyqtSignal(int)
    enable_button = pyqtSignal(bool)

class Window(QWidget):
    def __init__(self, *args, **kwargs):
        QWidget.__init__(self, *args, **kwargs)

        self.button = QPushButton("Run", self)
        self.button.clicked.connect(self.onButton)

        self.progress = QProgressBar(self)
        self.progress.setTextVisible(False)

        self.layout = QVBoxLayout()
        self.layout.setContentsMargins(5, 5, 5, 5)
        self.layout.addWidget(self.button)
        self.layout.addWidget(self.progress)
        self.layout.addStretch()

        self.worker_thread = QThread()
        self.worker_thread.run = self.worker
        self.worker_thread.should_close = False

        self.signals = Signals()
        self.signals.update.connect(self.progress.setValue)
        self.signals.enable_button.connect(self.button.setEnabled)

        self.setLayout(self.layout)
        self.show()
        self.resize(self.size().width(), 0)

    # Override
    def closeEvent(self, e):
        self.worker_thread.should_close = True
        self.worker_thread.wait()

    @pyqtSlot()
    def onButton(self):
        self.button.setDisabled(True)
        self.worker_thread.start()

    # Worker thread, no direct GUI updates!
    def worker(self):
        for i in range(101):
            if self.worker_thread.should_close:
                break
            self.signals.update.emit(i)
            sleep(0.1)
        self.signals.enable_button.emit(True)

app = QApplication(sys.argv)
win = Window()
sys.exit(app.exec_())

- Fenikso

---

我已经解决了装饰器的问题，现在它可以工作了，但是使用装饰器可能有点复杂。另一个问题——更新GUI（这个问题没有在我的代码中发布）通过连接到我用装饰器创建的线程的“完成”信号得到了解决。我将更新我的问题，并提供解决方案，以便其他人可以了解如何通过使用装饰器使方法并发工作。 - Victor Polevoy

我在你的代码中没有看到信号。我只看到self._finished_slot()。 - Fenikso

@VictorPolevoy 不要在问题中更新修复方法，应该撰写一个回答。 - Fenikso

Answer 2

虽然已经有 Fenikso 提供了解决方案，但使用装饰器来解决问题也是一种有趣的方式。

我已经将我的 qtthreaddecorator.py 更正为以下内容：

from PyQt4 import QtCore


class Worker(QtCore.QThread):
    threads = []

    def __init__(self, thread_name, function, *args, **kwargs):
        QtCore.QThread.__init__(self)

        self._thread_name = thread_name
        self._function = function
        self._args = args
        self._kwargs = kwargs

    def run(self):
        Worker.threads.append(self.currentThreadId())            
        self._function(*self._args, **self._kwargs)
        self.emit(QtCore.SIGNAL('finished()'))
        Worker.threads.remove(self.currentThreadId())


def qt_thread_decorator():
    def decorator(function):
        def wrapper(*args, **kwargs):
            worker = Worker(function.__name__, function, *args, **kwargs)

            def on_finish():
                worker.quit()

            worker.finished.connect(on_finish)
            worker.start()

            return worker
        return wrapper
    return decorator

在使用这个装饰器的代码中：

import qtthreaddecorator

class MainWindow(QtGui.QMainWindow, form_class):

    def __init__(self, parent=None):
        QtGui.QMainWindow.__init__(self, parent)
        self.setupUi(self)

        self.init()

    def init(self):
        @qtthreaddecorator.qt_thread_decorator()
        def _get_servers():
            self._get_my_servers()
        @qtthreaddecorator.qt_thread_decorator()
        def _get_user_info():
            self._get_user_info()

        _get_servers().finished.connect(self._fill_servers)
        _get_user_info().finished.connect(self._fill_user_info)

- Victor Polevoy

---

但我仍在思考worker.quit()何时实际上会销毁线程 - 在通知每个finished()订阅者之后还是之前？这可能会引起问题吗？ - Victor Polevoy

我建议使用新的信号符号。我认为旧的在PyQt5中已经被移除了。 - Fenikso