QT--线程

一、线程QThread

  • QThread 类提供不依赖平台的管理线程的方法,如果要设计多线程程序,一般是从 QThread继承定义一个线程类,在自定义线程类里进行任务处理。
  • qt拥有一个GUI线程,该线程阻塞式监控窗体,来自任何用户的操作都会被gui捕获到,并处理;如果有耗时的任务,不推荐在GUI中处理.怎么办?? 创建线程,交给线程去耗时!

1.QThread类简要说明

  1. 一个QThread类的对象管理一个线程。该线程包括
  • 执行函数体,这是线程执行的主要代码部分。
  • 函数体中有一个死循环,用于保持线程的持续运行,直到条件满足。
  • 线程私有空间,每个线程都有自己的独立数据和堆栈空间。
  1. QThread 提供了完整的线程功能,并且内置了一个虚函数 run() 用于处理线程任务。我们可以通过重写 run() 方法来定义线程的具体行为。编写线程的具体方法为继承QThread并重写run()函数。最好是直接定义一个线程类(实际上也这样做)。
  2. GUI线程和控件访问:只有主GUI线程可以访问和操作窗体上的控件。如果其他线程尝试直接访问这些控件,会导致程序崩溃。为了在线程中更新UI,可以使用信号和槽机制。
class MyThread : public QThread {Q_OBJECT
signals:void updateUI(int value);public:void run() override {for (int i = 0; i < 10; ++i) {emit updateUI(i); // 发出信号更新UIQThread::sleep(1);}}
};// 在主窗口类中连接信号和槽
connect(ptMyThread, &MyThread::updateUI, this, &MainWindow::updateUIFunction);
  1. 线程的启动和停止使用start()和stop()函数即可。这也是可以捕获的信号,可以用来连接槽函数,不过要加上ed。
  2. 出现了此类错误error: undefined reference to `vtable for myThread,那么就将该错误发生的头文件和函数体文件移除该工程,然后再添加进来。
  3. 代码举例
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

2.线程间通信

1.通过共享资源的方式可以进行线程间通信。

  1. 结构体通信
    1. 值得注意的就是使用之前要加锁,使用之后要解锁
QMutex buflock;//其实就是互斥信号量。
buflock.lock();
buflock.unlock();
    1. 结构体要在使用该结构体的线程中声明,定义在外面,方便其他线程使用或声明,当然互斥锁也要有哈。
    1. 一般通过构造函数传入或写出数据。
    1. 在重写run()函数里有while循环,或者是死循环,具体情况而定
    1. 当然也要有休眠函数,给其他线程一点时间执行嘛。
    1. 代码举例
//rethread.h
#ifndef RETHREAD_H
#define RETHREAD_H
#include<QThread>
#include<QMutex>struct msg_struct{int temp;int shidu;char des[128];
};class thread_write:public QThread{
public:thread_write();thread_write(struct msg_struct *pmsg,QMutex *pMutex);//写~thread_write();void run() override;//写。重写
private:struct msg_struct *pShareMsg;QMutex *pMutex;
};class thread_read:public QThread{
public:thread_read(struct msg_struct *pmsg,QMutex *pMutex);//写thread_read();~thread_read();void run() override;//重写
private:struct msg_struct *pShareMsg;QMutex *pMutex;};#endif // RETHREAD_H//rethread.cpp
#include "rethread.h"
#include<QDebug>thread_write::thread_write()
{}thread_write::thread_write(msg_struct *pmsg, QMutex *pMutex)
{pShareMsg = pmsg;this->pMutex=pMutex;
}thread_write::~thread_write()
{}void thread_write::run()
{char ch = 'A';while(1){pMutex->lock();for(int i= 0;i<127;i++){pShareMsg->des[i]=ch;if(i%20==0){QThread::sleep(1);}}pMutex->unlock();QThread::msleep(10);ch++;}
}thread_read::thread_read(msg_struct *pmsg, QMutex *pMutex)
{pShareMsg = pmsg;this->pMutex = pMutex;}thread_read::thread_read()
{}thread_read::~thread_read()
{}void thread_read::run()
{QThread::sleep(1);while(1){pMutex->lock();qDebug()<<"thread read"<<__func__<<" "<<pShareMsg->des;pMutex->unlock();QThread::sleep(5);}
}//widget.h
#ifndef WIDGET_H
#define WIDGET_H
#include"rethread.h"
#include <QWidget>QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();private:Ui::Widget *ui;struct msg_struct *pShareMsg;QMutex *pMutex;thread_read *pThreadRead;thread_write *pThreadWrite;
};
#endif // WIDGET_H//widget.cpp
#include "widget.h"
#include "ui_widget.h"Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);pShareMsg = new struct msg_struct;pMutex = new QMutex;pThreadRead  = new thread_read(pShareMsg,pMutex);pThreadWrite = new thread_write(pShareMsg,pMutex);pThreadWrite->start();pThreadRead->start();
}Widget::~Widget()
{delete ui;
}

在这里插入图片描述

  1. 信号和槽
  • 在一个线程中定义一个信号,然后将其连接到另一个线程中的槽函数,通过信号的触发来调用槽函数。这是Qt中最常用的线程间通信方法。
  • 这之中有一个线程铁定是GUI线程。才可以使用信号和槽
  • 例如
    在这里插入图片描述
    输出为
    在这里插入图片描述
  • 值得注意的是不要在GUI程序中加入sleep睡眠之类的代码,容易造成程序崩溃。

3.线程间同步

  • 线程同步是指在多线程环境中,协调线程之间的执行顺序和数据共享,确保线程以预期的方式访问共享资源。同步的主要目的是避免竞争条件(race conditions)和数据不一致性。
1.基于互斥量的线程同步QMutex
  1. 互斥量可以保证在任意时刻只有一个线程可以访问共享资源,从而避免竞争条件和数据不一致性。
  2. 定义一把互斥锁
//widget.h
QMutex *pMutex;
//widget.cpp
pMutex = new QMutex;
  1. 上锁,如果互斥量已经被其他线程锁定,当前线程将被阻塞,直到互斥量可用。
pMutex.lock();
  1. 解锁,访问共享资源后,线程需要释放互斥量的锁,以便其他线程可以访问该资源。
pMutex.unlock();
  1. 尝试上锁,函数tryLock()尝试锁定一个互斥量,如果成功锁定就返回true,如果其他线程已经锁定了这个互斥量就返回false,不等待。有参数则等待。
pMutex.try_Lock();//括号内可以有参数,以毫秒为单位,表示最多等待多少毫秒
2. 基于读写锁的线程同步QReadWriteLock
  • 基于读写锁(Read-Write Lock)的线程同步是一种高效的同步机制,适用于读多写少的场景。与互斥锁不同,读写锁允许多个线程同时读取共享资源,但在写入资源时,只允许一个线程进行写操作,这样可以提高程序的并发性能。
  1. 定义一把读写锁
//widget.h
QReadWriteLock *pRWLock;
//Widget.cpp
pRWLock = new QReadWriteLock;
  1. pRWLock.lockForRead();//以只读方式锁定资源,如果有其他线程以写入方式锁定资源,这个函数会被阻塞
  2. pRWLock.lockForWrite();//以写入方式锁定资源,如果其他线程以读或写方式锁定资源,这个函数会被阻塞
  3. pRWLock.unlock();//解锁
  4. 它们可以在前面加上try,如tryLockForRead();表示尝试以读的方式锁上资源,括号内的参数可以表示尝试多少毫秒
3. 基于条件等待的线程同步QWaitCondition
  • QWaitCondition 提供了一种改进的线程同步方法,QWaitCondition 通过与 QMutex QReadWriteLock 结合使用,可以使一个线程在满足一定条件时通知其他多个线程,使其他多个线程及时进行响应,这样比只使用互斥量或读写锁效率要高一些。
  • 定义

QMutex mutex;
QReadWriteLock readWriteLock;
QWaitCondition condition;
  1. bool wait(QMutex *lockedMutex, unsigned long time = ULONG_MAX),释放lockMutex这个互斥信号量。线程进入休眠,等待被唤醒,默认无限等待。若被唤醒则返回true;若超时则返回false。
  2. bool wait(QReadWriteLock *lockedReadWriteLock, unsigned long time = ULONG_MAX),释放lockedReadWriteLock这个读写锁,并让线程进入等待状态直到被唤醒或者超时。默认情况下,无限期等待。若被唤醒则返回true;若超时则返回false。
  3. void wakeAll():唤醒所有处于等待状态的线程。唤醒顺序不确定,由操作系统的调度策略决定。
  4. void wakeOne():唤醒一个处于等待状态的线程。具体唤醒哪个线程不确定,由操作系统的调度策略决定。
4. 基于信号量的线程同步
  • 信号量(QSemaphore)是用于控制多个线程对共享资源的访问的同步原语。它是一种计数器,允许你在特定时间允许多个线程同时访问某个资源。信号量可以用来限制访问的线程数。
  1. 使用方法
方法名描述参数返回值
构造函数
QSemaphore(int initialCount = 1, int maxCount = 1)创建一个信号量,初始计数和最大计数。initialCount:初始计数值
maxCount:最大计数值
基本方法
acquire(int num = 1)获取 num 个资源,若资源不足,线程阻塞。num:需要获取的资源数量
release(int num = 1)释放 num 个资源,增加信号量的计数器。num:需要释放的资源数量
带超时的方法
acquire(int num, unsigned long timeout = ULONG_MAX)获取 num 个资源,直到超时。num:需要获取的资源数量
timeout:超时时间(毫秒)
bool:成功获取资源返回 true,超时返回 false
检查方法
tryAcquire(int num = 1)尝试获取 num 个资源,若资源不足则立即返回。num:需要获取的资源数量bool:成功获取资源返回 true,否则返回 false
available() const返回可用资源的数量。int:可用资源数量
其他方法
setCount(int count)设置信号量的计数器值。count:新的计数值
maximumCount() const返回信号量的最大值。int:最大值
currentCount() const返回当前信号量的计数值。int:当前计数值
  1. 代码示例
#include <QCoreApplication> // 引入Qt核心应用程序模块
#include <QThread>          // 引入Qt线程模块
#include <QSemaphore>       // 引入Qt信号量模块
#include <QDebug>           // 引入Qt调试输出模块// 创建一个信号量,初始计数为3,表示最多同时允许3个线程访问资源
QSemaphore semaphore(3);class Worker : public QThread {
public:void run() override { // 重写QThread的run()方法,定义线程执行的代码// 尝试在1000毫秒内获取一个资源if (semaphore.tryAcquire(1, 1000)) { // 尝试获取一个资源,如果在超时内未能获取,则返回falseqDebug() << "Thread" << QThread::currentThreadId() << "acquired a resource."; // 打印线程获取资源的消息QThread::sleep(2); // 模拟工作,线程休眠2秒qDebug() << "Thread" << QThread::currentThreadId() << "finished working."; // 打印线程完成工作的消息semaphore.release(); // 释放一个资源,使其他等待的线程可以获取到资源} else {qDebug() << "Thread" << QThread::currentThreadId() << "could not acquire a resource within timeout."; // 打印超时未获取资源的消息}// 显示信号量的状态qDebug() << "Current available resources:" << semaphore.available(); // 打印当前可用资源的数量semaphore.setCount(5); // 修改信号量的计数器值为5,增加可用资源qDebug() << "Max count:" << semaphore.maximumCount(); // 打印信号量的最大计数值qDebug() << "Current count:" << semaphore.currentCount(); // 打印当前信号量的计数值}
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv); // 创建Qt应用程序实例// 创建多个Worker线程实例Worker worker1, worker2, worker3, worker4, worker5;// 启动线程worker1.start();worker2.start();worker3.start();worker4.start();worker5.start();// 等待所有线程完成worker1.wait();worker2.wait();worker3.wait();worker4.wait();worker5.wait();return a.exec(); // 进入Qt事件循环
}

QT睡眠程序

  • 用于让当前线程休眠或延迟执行
  1. QThread::sleep(int sec);//个方法使当前线程休眠指定的秒数。
  2. QThread::msleep(int msec);//这个方法使当前线程休眠指定的毫秒数。
  3. QThread::usleep(int usec);//这个方法使当前线程休眠指定的微秒数。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/876657.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【PyQt5】一文向您详细介绍 setPlaceholderText() 的作用

【PyQt5】一文向您详细介绍 setPlaceholderText() 的作用 下滑即可查看博客内容 &#x1f308; 欢迎莅临我的个人主页 &#x1f448;这里是我静心耕耘深度学习领域、真诚分享知识与智慧的小天地&#xff01;&#x1f387; &#x1f393; 博主简介&#xff1a;985高校的普通…

脑网络布线成本优化——从Caja守恒原则到最小化成本的探索

脑网络布线成本优化——从Caja守恒原则到最小化成本的探索 Caja守恒原则的核心作用 Caja守恒原则&#xff0c;即大脑组织的布线成本最小化原则&#xff0c;是神经科学中的一个重要概念。它指出&#xff0c;大脑在组织结构上倾向于最小化连接神经元以构成环路或网络所涉及的布…

【MySQL】记录MySQL加载数据(LOAD DATA)

MySQL LOAD DATA 一、背景二、模拟生成用户信息三、加载到mysql表3.1、建表语句3.2 加载数据3.3、查看结果 一、背景 现在有个需求是将用户信息存入student.data文件中&#xff0c;在现在load到数据库中 二、模拟生成用户信息 假设用户信息&#xff0c;包含姓名&#xff0c;…

C++和R穿刺针吸活检肿瘤算法模型模拟和进化动力学量化差异模型

&#x1f3af;要点 &#x1f3af;模拟肿瘤细胞增生进化轨迹 | &#x1f3af;肿瘤生长的随机空间细胞自动机模型 | &#x1f3af;模拟穿刺活检的收集空间局部的肿瘤块&#xff0c;模拟针吸活检采集长而薄的组织样本 | &#x1f3af;构建不同参数模拟合成肿瘤测试集 | &#x1f…

LangChain--如何使用大模型

【&#x1f34a;易编橙终身成长社群&#x1f34a;】 大家好&#xff0c;我是小森( &#xfe61;ˆoˆ&#xfe61; ) &#xff01; 易编橙终身成长社群创始团队嘉宾&#xff0c;橙似锦计划领衔成员、阿里云专家博主、腾讯云内容共创官、CSDN人工智能领域优质创作者 。 LangCha…

Linux——简介

Linux的组成 Linux系统一般由四个主要部分组成&#xff1a;内核、shell、文件系统和应用程序。 内核&#xff1a;是操作系统的核心&#xff0c;负责管理系统的进程、内存、设备驱动程序、文件和网络系统等&#xff0c;决定着系统的性能和稳定性。shell&#xff1a;是系统的用…

2024:Qt--编译配置Protobuf(windows10) 配图详解

这里写自定义目录标题 一、准备1、Window10系统2、Qt Creator 5.0.2 Based on Qt 5.15.2 (MSVC 2019, 64 bit)3、protobuf-3.15.0&#xff08;本示例使用版本&#xff09;4、cmake-3.21.3-windows-x86_64&#xff08;本示例使用&#xff0c;下载的zip直接解压使用&#xff09; …

自编码器(autoencoder)

1.自编码器的由来 最初的自编码器是用来降维的&#xff0c;后来也逐渐用于去噪、生成任务。 2.自编码器的基本结构 自编码器&#xff08;autoencoder&#xff09;内部有一个隐藏层 h&#xff0c;可以产生编码&#xff08;code&#xff09;表示输入。该网络可以看作由两部分组…

ArcGIS Desktop使用入门(四)——ArcMap软件彻底卸载删除干净

系列文章目录 ArcGIS Desktop使用入门&#xff08;一&#xff09;软件初认识 ArcGIS Desktop使用入门&#xff08;二&#xff09;常用工具条——标准工具 ArcGIS Desktop使用入门&#xff08;二&#xff09;常用工具条——编辑器 ArcGIS Desktop使用入门&#xff08;二&#x…

支持向量机回归及其应用(附Python 案例代码)

使用支持向量机回归估计房价 让我们看看如何使用支持向量机&#xff08;SVM&#xff09;的概念构建一个回归器来估计房价。我们将使用sklearn中提供的数据集&#xff0c;其中每个数据点由13个属性定义。我们的目标是根据这些属性估计房价。 引言 支持向量回归&#xff08;SV…

vim的使用及退出码(return 0)

linux基础之vim快速入门 linux基础之vim快速入门_基本linux vim-CSDN博客https://blog.csdn.net/ypxcan/article/details/119878137?ops_request_misc&request_id&biz_id102&utm_termvim%E7%BC%96%E8%BE%91%E5%99%A8%E5%A4%8D%E5%88%B6%E7%B2%98%E8%B4%B4%E4%BA%…

Java(十)——接口

个人简介 &#x1f440;个人主页&#xff1a; 前端杂货铺 ⚡开源项目&#xff1a; rich-vue3 &#xff08;基于 Vue3 TS Pinia Element Plus Spring全家桶 MySQL&#xff09; &#x1f64b;‍♂️学习方向&#xff1a; 主攻前端方向&#xff0c;正逐渐往全干发展 &#x1…

JAVA零基础学习3(Scanner类,字符串,StringBuilder,StringJoinder,ArrayList成员方法)

JAVA零基础学习&#xff13; Scanner类输入示例代码代码解释完整代码1. 读取字符串2. 读取整数3. 读取浮点数4. 读取布尔值5. 读取单个单词6. 读取长整型数7. 读取短整型数8. 读取字节数注意事项总结 API 字符串解释示例解释解决方法示例&#xff1a;使用 StringBuilder String…

口碑爆棚的高分法国电影,一起在光影中领略法式魅力吧!

文章目录 引言《与玛格丽特的午后》(网友评分:9.1)《午夜巴黎》(网友评分:8.3)《玫瑰人生》(网友评分:8.4)《双姝奇缘》(网友评分:8.7)《巴黎淘气帮》(网友评分:8.6)《触不可及》(网友评分:9.3)《爱在日落黄昏时》(网友评分:8.9)《悲惨世界》(网友评分:…

VScode使用Github Copilot插件时出现read ECONNREST问题的解决方法

文章目录 read ECONNREST查看是否仍是 Copilot 会员查看控制台输出网络连接问题浏览器设置问题笔者的话 read ECONNREST 最近使用 Copilot 时一直出现 read ECONNREST 问题&#xff0c;这个表示连接被对方重置了&#xff0c;就是说在读取数据时连接被关闭。 我首先怀疑是不是…

[023-2].第2节:SpringBoot中接收参数相关注解

我的后端学习大纲 SpringBoot学习大纲 1.1.基本介绍&#xff1a; SpringBoot接收客户端提交的数据、参数会使用的一些注解&#xff1a; 1.PathVarible2. RequestHeader3.RequestParam4.CookieValue5.RequestBody6.RequestAttribute 1.2.接收参数相关注解与应用实例&#xff1a;…

无人机制造工艺流程详解

一、需求分析 无人机制造的第一步是需求分析。这一阶段主要明确无人机的使用场景、功能要求、性能指标以及成本预算等。通过与客户或项目团队的深入沟通&#xff0c;确保对无人机的需求有全面而准确的理解。同时&#xff0c;也需要进行市场调研&#xff0c;了解同类型产品的特…

科普文:docker基础概念、软件安装和常用命令

docker基本概念 一 容器的概念 1. 什么是容器&#xff1a;容器是在隔离的环境里面运行的一个进程&#xff0c;这个隔离的环境有自己的系统目录文件&#xff0c;有自己的ip地址&#xff0c;主机名等。也可以说&#xff1a;容器是一种轻量级虚拟化的技术。 2. 容器相对于kvm虚…

如何使用 SQLite ?

SQLite 是一个轻量级、嵌入式的关系型数据库管理系统&#xff08;RDBMS&#xff09;。它是一种 C 库&#xff0c;实现了自给自足、无服务器、零配置、事务性 SQL 数据库引擎。SQLite 的源代码是开放的&#xff0c;完全在公共领域。它被广泛用于各种应用程序&#xff0c;包括浏览…

【C语言】函数的递归

目录 一、什么是递归 二、递归的思想 三、递归的限制条件 四、递归中的栈溢出 五、递归举例 &#xff08;1&#xff09;例1&#xff1a;n的阶乘 &#xff08;2&#xff09;例子2&#xff1a;顺序打印一个数的每一位 六、递归和迭代 七、拓展题目 &#xff08;1&#…