Pyqt5 多线程 QThread 要如何创建多个线程呢？

[itIsUnbelievable]

我写了一个类继承 QObject,然后用 movetothread 将前面那个实例放入一个继承 Qthread 的线程类，通过信号槽来连接。但是由于我接触 pyqt 没多久，对多线程这块不太熟，目前我只知道创建一个子线程将 ui 和业务逻辑分开，不知道怎么创建多个线程同时处理。我的业务场景是点击一个按钮同时对 16 个文件夹中的视频文件进行人脸分析，用 opencv 和百度云人脸识别 api。现在卡在如何创建多个线程这里了，第一次发帖，希望 v 站的老哥给点建议。非常感谢。

[chengxiao]

Qthread 里只放线程里的运行代码,要多个线程就直接循环创建多个 Qthread 类实例就好了啊

[itIsUnbelievable]

@chengxiao
```
class BaiduYunObject(QObject):
stop_procession_signal=pyqtSignal()

def __init__(self,parent=None):
super(BaiduYunObject,self).__init__(parent)

def main(self):
print(11)
self.stop_procession_signal.emit()



class BaiduYunProcessingThread(QObject):
def __init__(self,detect_url,search_url,add_url,multi_search_url):
super().__init__()
self.process_thread= QThread()
self.process_thread1= QThread()
self.procession=BaiduYunObject()
self.procession.moveToThread(self.process_thread1)
self.procession.moveToThread(self.process_thread)
self.process_thread.started.connect(self.procession.main)
self.process_thread1.started.connect(self.procession.main)
self.procession.stop_procession_signal.connect(self.stop_process) #线程结束信号槽
self.process_thread.start()
self.process_thread1.start()

def stop_process(self):
self.process_thread.quit()

```
我创建了两个线程实例测试了下，是能打印出两个 11.但是 11 前面报了下面这个错误：
QObject::moveToThread: Current thread (0x1d0369badf0) is not the object's thread (0x1d068d35530).
Cannot move to target thread (0x1d068d35f50)

所以我有点疑问，不知道这样创建合不合理。而且还有个问题是如何使用循环创建多个线程实例，比如创建 16 个线程应该如何用 for 循环动态创建变量，毕竟 format()只能用于字符串，如果想要循环创建形如 process_thread_1,process_thread_2 这样的变量该怎么创建呢，我试过 locals()，但没成功，希望能给点建议。

[itIsUnbelievable]

@chengxiao 而且我把 main()函数改成
for i in range(10):
print(i)
发现两个线程不是并发的，而是一个线程运行结束后再运行另一个。
输出为 01234567890123456789

[chengxiao]

额....
@itIsUnbelievable 因为你的程序没有写进 Qhtread 里啊 缩进太乱没看懂
不过我感觉你的 BaiduYunObject 应该继承 Qthread 而不是 Qobject
然后生成的 BaiduYunObject 的实例就是线程运行
BaiduYunProcessingThread 这个也写的有问题 建议还是看看 pyqt 的线程案例照着写一个吧

[allenforrest]

可以改用 QThreadPool 和 QRunnable，管理线程更简单。
每个要处理的任务，都定义成 QRunnable 对象的子类，实现 Run 方法。
然后主线程创建 threadPool，每次要创建一个线程干活的时候，就 start 一个 QRunnable 对象即可，把对象的 autoDelete 设置为 true，run 跑完就自动销毁回收线程了。

[itIsUnbelievable]

@chengxiao 继承 Qthread 然后运行 run()方法的那种写法我之前试过，不过 google 了好久发现说 QT 的作者不支持这种写法，所以改成继承了 QObject 这种写法。https://blog.csdn.net/qq_39607437/article/details/79213717 他是这么说的：
```
QtCore.QThread 是一个管理线程的类，当我们使用其构造函数的时候，便新建了一个线程。这里要强调，QThread 是一个线程管理器，不要把业务逻辑放在这个类里面，Qt 的作者已经多次批评继承 QThread 类来实现业务逻辑的做法。
```
我就是按照这篇修改了写法。但是他也没讲这种写法创建很多个线程要怎么弄，所以我就试着创建多个线程实例，并将负责复杂计算业务逻辑的那个类实例放入线程类当中，现在的结果就如上面所说，线程好像不是同时运行的。 我现在很懵逼

[itIsUnbelievable]

重新发下这部分代码：在 UI 主线程实现点击按钮后创建一个 BaiduYunProcessingThread 类实例。
class BaiduYunObject(QObject):
stop_procession_signal=pyqtSignal()

def __init__(self,parent=None):
super(BaiduYunObject,self).__init__(parent)

def main(self):
for i in range(10):
print(i)
self.stop_procession_signal.emit()

class BaiduYunProcessingThread(QObject):
def __init__(self):
super().__init__()
self.process_thread= QThread()
self.process_thread_1= QThread()
self.procession=BaiduYunObject()
self.procession.moveToThread(self.process_thread_1)
self.procession.moveToThread(self.process_thread)
self.process_thread.started.connect(self.procession.main)
self.process_thread_1.started.connect(self.procession.main)
self.procession.stop_procession_signal.connect(self.stop_process) #线程结束信号槽
self.process_thread.start()
self.process_thread_1.start()

def stop_process(self):
self.process_thread.quit()

[itIsUnbelievable]

@allenforrest 好的，非常感谢，我先去了解一下，感觉好像很有用。

[allenforrest]

@itIsUnbelievable 对，这代码多干净：

#include <QCoreApplication>
#include <QThreadPool>
#include <QThread>
#include <QRunnable>
#include <QDebug>
class MyRun : public QRunnable {
public:
void run() {
int i=3;
while(i) {
i--;
QThread::msleep(500);
}
}
};
int main(int argc, char *argv[]) {
QCoreApplication a(argc, argv);
QThreadPool m;
MyRun *run=new MyRun;
if(!run->autoDelete()) {
run->setAutoDelete(true);
}
m.start(run);

m.waitForDone();
return 0;
}

[itIsUnbelievable]

@allenforrest 我刚才看到这样一句话：
```
需要注意的是，QRunnable 不是一个 QObject，因此也就没有内建的与其它组件交互的机制。为了与其它组件进行交互，你必须自己编写低级线程原语，例如使用 mutex 守护来获取结果等。
```
我想问下 QRunnable 支不支持信号槽机制呢？还有就是它可不可以在子线程中继续创建子线程？这个时候线程的执行顺序该如何保证呢？是要用 python 的 queue 吗？

[allenforrest]

@itIsUnbelievable 可以同时继承 QRunnable 和 QObject 哈

[woshidag]

可以参考这个 PYQT5 的 QRunnable 的 demo https://www.learnpyqt.com/courses/concurrent-execution/multithreading-pyqt-applications-qthreadpool/

[itIsUnbelievable]

@allenforrest 谢谢，我昨天看了一篇 QT 的文章就是继承了 QObject，我也就照着做了。而且在子线程中又创建了一个 threadPool，想要创建子线程就再 new 一个新的 runnable 类，测试了一下是可以在子线程下再创建子线程的。就是不太清楚线程中的共享数据问题

[itIsUnbelievable]

@woshidag 这篇讲的也太好了吧，amazing，谢谢老哥！