当前位置: 首页 > news >正文

1. 多线程开发

目录

  • 方法1.继承QThread
    • 使用案例
    • 总结
  • 方法2.将qobject对象moveToThread(官方推荐)
    • 使用案例
    • 总结
  • 方法3.QRunnable + QThreadPool
    • 使用案例
    • 总结
  • 方法4.快速线程QtConcurrent+QFutureWatcher
    • 使用案例
    • 总结

方法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()
​处理异常​:确保并行函数不会抛出未捕获的异常

http://www.dtcms.com/a/298946.html

相关文章:

  • Ansible列出常见操作系统的发行版,Ansible中使用facts变量的两种方式
  • pytorch学习笔记-自定义卷积
  • 【CTF-WEB-SQL】SQL注入基本流程-错误注入(sql-labs的Less5)(updatexml)
  • 常见代码八股
  • 房价预测|Pytorch
  • 【Android】约束布局总结(1)
  • 数据结构预备知识
  • Linux的生态与软件安装
  • 基于深度学习的图像分类:使用Inception-v3实现高效分类
  • Coze 与 Dify 深度对比:2025 年 AI 智能体平台选型指南
  • 【MySQL】深入浅出事务:保证数据一致性的核心武器
  • GStreamer与OpenCV集成
  • 【RocketMQ】一分钟了解RocketMQ
  • Linux系统调用概述与实现:深入浅出的解析
  • 2025.7.26
  • 50道JavaScript基础面试题:从基础到进阶
  • 【图像分割】记录1:unet, yolov8_seg
  • 【嵌入式电机控制#20】无刷直流电机硬件案例
  • 详解力扣高频SQL50题之619. 只出现一次的最大数字【简单】
  • 【ELasticsearch】节点角色分类与作用解析
  • SQL 通用数据类型
  • C# 判断语句深度解析
  • 详解力扣高频SQL50题之1084. 销售分析 III【简单】
  • 基于 Claude Code 与 BrowserCat MCP 的浏览器自动化全链路构建实践
  • OGG同步Oracle到Kafka不停库,全量加增量
  • 显式等待和隐式等待的区别
  • JavaScript 立即执行函数(IIFE)运行时行为分析笔记
  • 数控滑台的功能与应用
  • 生产环境使用云服务器(centOS)部署和使用MongoDB
  • MongoDB数据模型