1. Qt多线程开发

方法1.继承QThread

需要实现QThread的抽象函数run

#ifndef WORKERTHREAD_H
#define WORKERTHREAD_H#include <QObject>
#include <QThread>
#include <QDebug>class WorkerThread : public QThread
{Q_OBJECT
public:explicit WorkerThread(QObject *parent = nullptr);void func1();protected:virtual void run();signals:
};#endif // WORKERTHREAD_H#include "workerthread.h"WorkerThread::WorkerThread(QObject *parent): QThread{parent}
{}void WorkerThread::func1()
{qDebug()<< __FUNCTION__<< QThread::currentThread();
}void WorkerThread::run()
{qDebug()<< __FUNCTION__<< QThread::currentThread();
}

使用案例

#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);qDebug()<< "主线程:" << QThread::currentThread();wt = new WorkerThread(this);wt->start();//执行WorkerThread的run在子线程中wt->func1();    //主线程connect(ui->pushButton,&QPushButton::clicked,wt,&WorkerThread::func1); //主线程}Widget::~Widget()
{delete ui;
}

总结

run函数是在子线程中执行的
其成员函数func1
a)直接调用的方式是在创建对象的线程（主线程）中执行的
b)信号槽连接的方式也是在创建对象的线程（主线程）中执行的

直接调用接口，如果包含了run线程中使用的变量可能就会导致数据竞争
此时就得考虑加锁
如果run线程中获取到了锁，主线程调用WorkerThread的接口会导致阻塞，界面卡顿=
使用场景，不需要进行线程间数据交互

方法2.将qobject对象moveToThread（官方推荐）

#ifndef WORKER_H
#define WORKER_H#include <QObject>class Worker : public QObject
{Q_OBJECT
public:explicit Worker(QObject *parent = nullptr);~Worker();void func1();signals:
};#endif // WORKER_H
#include "worker.h"
#include <QThread>
#include <QDebug>Worker::Worker(QObject *parent): QObject{parent}
{}Worker::~Worker()
{
qDebug()<< __FUNCTION__ << QThread::currentThread();
}void Worker::func1()
{qDebug()<< __FUNCTION__ << QThread::currentThread();
}

使用案例

#ifndef FORM_H
#define FORM_H#include <QWidget>
#include <QThread>
#include <QDebug>#include "worker.h"namespace Ui {
class Form;
}class Form : public QWidget
{Q_OBJECTpublic:explicit Form(QWidget *parent = nullptr);~Form();
signals:void closeThread();private:Ui::Form *ui;
};#endif // FORM_H
#include "form.h"
#include "ui_form.h"Form::Form(QWidget *parent): QWidget(parent), ui(new Ui::Form)
{ui->setupUi(this);//根据亲和性，不应设置为其他线程的成员对象QThread *th = new QThread();Worker *worker = new Worker();qDebug()<< "主线程:" << QThread::currentThread();worker->moveToThread(th);connect(th,&QThread::finished,worker,&Worker::deleteLater);connect(th,&QThread::finished,worker,&QThread::deleteLater);th->start();    //启动子线程worker->func1();    //错误行为connect(ui->pushButton,&QPushButton::clicked,worker,&Worker::func1); //正确线程间通信connect(this,&Form::closeThread,th,&QThread::quit); //关闭线程
}Form::~Form()
{delete ui;emit closeThread();}

总结

使用场景: 线程之间频繁交互的时候（官方推荐）

①禁止行为：禁止直接调用子线程对象接口或者修改数据
因为这会导致跨线程访问问题，可能引发数据竞争、死锁或程序崩溃。
应该通过信号槽连接进行线程间通信。

②独立的事件循环
子线程开启会产生一个独立的事件循环，此时异步线程信号请求会在此次统一处理
不会对发起请求的线程阻塞；

③Qt 的父子对象与线程规则​
​规则 1​：所有 QObject 父子对象必须位于同一线程。
​规则 2​：调用 moveToThread() 会改变对象的线程亲和性（Thread Affinity）。
​冲突点​：如果将一个已移动到子线程的 QObject 设置为另一个线程中对象的子对象，Qt 会触发断言崩溃（如 QObject: Cannot create children for a parent that is in a different thread）。
简单点说既是；A线程中的对象不应该成为B线程的父对象或者子对象

方法3.QRunnable + QThreadPool

#ifndef WORKERTASK_H
#define WORKERTASK_H#include <QRunnable>class WorkerTask : public QRunnable
{
public:WorkerTask();~WorkerTask();
protected:virtual void run();
};#endif // WORKERTASK_H
#include "workertask.h"
#include <QThread>
#include <QDebug>WorkerTask::WorkerTask() {setAutoDelete(true);
}WorkerTask::~WorkerTask()
{
qDebug()<< __FUNCTION__<< QThread::currentThread();
}void WorkerTask::run()
{
qDebug()<< __FUNCTION__<< QThread::currentThread();
}

使用案例

#ifndef FORM1_H
#define FORM1_H#include <QWidget>
#include <QThread>
#include <QDebug>namespace Ui {
class Form1;
}class Form1 : public QWidget
{Q_OBJECTpublic:explicit Form1(QWidget *parent = nullptr);~Form1();private:Ui::Form1 *ui;
};#endif // FORM1_H
#include "form1.h"
#include "ui_form1.h"
#include "workertask.h"
#include <QThreadPool>Form1::Form1(QWidget *parent): QWidget(parent), ui(new Ui::Form1)
{ui->setupUi(this);qDebug()<< "主线程:" << QThread::currentThread();QThreadPool::globalInstance()->start(new WorkerTask());}Form1::~Form1()
{delete ui;
}

总结

场景：适合短生命周期的任务
用完就释放

方法4.快速线程QtConcurrent+QFutureWatcher

其他线程都得创建一堆的对象，管理对象的创建与释放生命周期，
但是QtConcurrent不用，使用QtConcurrent我们可以快速开启一个线程

使用案例

#include "form2.h"
#include "ui_form2.h"
#include <QDebug>
#include <QThread>
#include <QtConcurrent>
#include <QtConcurrent/QtConcurrentMap>Form2::Form2(QWidget *parent): QWidget(parent), ui(new Ui::Form2)
{ui->setupUi(this);qDebug()<< "主线程:" << QThread::currentThread();
}Form2::~Form2()
{delete ui;
}void Form2::on_pushButton_clicked()
{QList<int> list = {1, 2, 3, 4, 5};//通过map开启多个线程执行， 如果使用for每个元素处理是耗时的，但是采用此法可以并行处理// QFuture<void> future = QtConcurrent::map(list, [](int &value) {//     value *= 2; // 将每个元素乘以2//     qDebug()<< __FUNCTION__ << QThread::currentThread();// });QFuture<int> future = QtConcurrent::run([]() -> int {// 计算并返回结果return 42;});qDebug()<< future.result(); //阻塞等待结构
}

绑定监听器，全部执行完则发出fnish信号

QFutureWatcher<void> watcher;
connect(&watcher, &QFutureWatcher<void>::finished, this, []() {qDebug() << "图像处理完成";
});watcher.setFuture(future);

总结

​避免修改共享数据​：尽量使用值传递而非引用传递
​使用轻量级函数​：并行执行的函数应该尽可能轻量
​合理设置线程池大小​：使用 QThreadPool::globalInstance()->setMaxThreadCount()
​处理异常​：确保并行函数不会抛出未捕获的异常

代码下载

链接: 下载