如何将变量传递给 QThread（PySide 或 PyQT）

Question

我真的很难完成需要多个不同线程的 GUI 应用程序的编写。在高层次上，我需要：

一个 GUI 线程，它有一个按钮来打开用户选择目录的目录浏览器。在选择目录时，线程启动以查找特定文件类型。这可能需要很长时间，所以我知道我需要放入一个单独的 QThread。

然后一旦 browseFile 线程完成文件搜索，它 return 就是一个文件列表，然后将其分块到子文件列表中。然后将每个子文件列表发送到单独的线程进行处理，这将花费大量时间。

这是我目前编写的代码：

from PyQt4 import QtCore
from PyQt4 import QtGui
from PyQt4.QtCore import * 
import os

class BrowseThread(QThread):
    processdone = QtCore.pyqtSignal("QString") # Define custom signal.

    def __init__(self, parent, *args, **kw):
        QThread.__init__(self, parent)
        self.search(*args, **kw)

    def search(self, directory_path):
        self.fileList = []
        self.count = 0
        for dirname, dirnames, filenames in os.walk(directory_path):
            for filename in filenames:
                if filename.endswith(".gz"):
                    self.fileList.append(os.path.join(directory_path,filename))

        self.emit( SIGNAL('processdone'), "DONE")

        return     

class MyClass(QObject):

    def __init__(self):            
        super(MyClass, self).__init__()

        directory_path = r'C:\Data'

        thread1 = BrowseThread(self, directory_path) 
        self.connect( thread1, SIGNAL("processdone"), self.thread1done)  
        thread1.start()  

    def thread1done(self, text):
        print(text)
        sys.exit()

if __name__ == "__main__":
    import sys
    app = QtGui.QApplication(sys.argv)  
    a = MyClass()
    sys.exit(app.exec_())

有没有比使用 *args, **kw 更好的方法将目录路径传递给 browseThread？

我怎样才能 return 将 fileList 返回到主线程，然后我可以将其传递给许多新的处理线程。

我确信我做的比应该做的更难，所以希望有人能帮助我

谢谢

Answer 1

你应该可以使用QT的信号槽机制。

http://doc.qt.io/qt-5/threads-qobject.html#signals-and-slots-across-threads

您也可以使用消息传递系统。

将它作为 arg 传递也没有错。请确保您安全地进行操作：https://web.archive.org/web/20150423115746/http://effbot.org/zone/thread-synchronization.htm

Answer 2

我建议将您的代码设计更改为具有真正工作的工作人员 class 的解决方案。这个 worker class 会像这样移动到普通线程（我不知道 PyQt 但它应该与 C++ 版本非常相似）：

class SearchWorker(QObject):
    finished_sig = QtCore.pyqtSignal('')  # finished signal

    def __init__(self, your_stuff):
        self.directory_path = ...

    def process_slot(self):
        # use self.directory_path
        # your code
        self.emit(SIGNAL('finished_sig'), '')

现在的主要部分是将启动信号连接到 class MyClass 中的工作人员。这在 C++ 中给出了这样的东西：

QThread* thread = new QThread;
Worker* worker = new Worker();
worker->moveToThread(thread);
// The start signal will actually launch your search method in the worker
connect(thread, SIGNAL(started()), worker, SLOT(process_slot()));
connect(worker, SIGNAL(finished()), thread, SLOT(quit()));

// May be useless in python
connect(worker, SIGNAL(finished_sig()), worker, SLOT(deleteLater()));
connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
thread->start();

优点是您可以在有或没有线程的情况下使用 worker，并且可以通过 setter 方法轻松地将参数传递给 worker。

要了解有关线程的 Qt 信号和槽的更多信息，我建议您阅读：

如何将变量传递给 QThread（PySide 或 PyQT）

How to pass variable to QThread (PySide or PyQT)

python

multithreading

pyqt

pyside