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

系统讨论Qt的并发编程2——介绍一下Qt并发的一些常用的东西

目录

QThreadPool与QRunnable

互斥机制:QMutex, QMutexLocker, QSemaphore, QWaitCondition

跨线程的通信

入门QtConcurrent,Qt集成的一个并发框架

一些参考


QThreadPool与QRunnable

QThreadPool自身预备了一些QThread。这样,我们就不需要频繁的创建和销毁我们的QThread,从而提升了性能。每个 Qt 应用程序都有一个全局 QThreadPool 对象,可以通过调用 globalInstance() 来访问。

那么,我们应该如何启动QThreadPool呢?答案是——使用一个接口叫做QRunnable。QRunnable自身只是要求你实现一个接口。那就是run接口。QRunnable自身不是一个QObject,意味着他是没有信号与槽的,适合那些跟Qt关系不大的,或者说跨线程之间没有对象交互的场景。

#include "Counter.h"
#include <QDebug>
#include <QRandomGenerator>
#include <QThread>
Counter::Counter() {
}
​
void Counter::run() {qInfo() << "Starting the job!";for (int i = 0; i < 20; i++) {qInfo() << QThread::currentThread() << "" << i;auto sleep_time = QRandomGenerator::global()->bounded(1, 100);QThread::msleep(sleep_time);}qInfo() << "Job done!";
}

在我们的主线程中,直接将Runable的子类对象传递给我们的QThreadPool,我们的QThreadPool回直接调用内部的run函数执行:

#include "Counter.h"
#include <QCoreApplication>
#include <QThreadPool>
​
int main(int argc, char* argv[]) {QCoreApplication a(argc, argv);QThread::currentThread()->setObjectName("Main");
​QThreadPool* pool = QThreadPool::globalInstance();qInfo() << pool->maxThreadCount();
​for (int i = 0; i < 100; i++) {Counter* counter = new Counter();counter->setAutoDelete(true);pool->start(counter);}
​return a.exec();
}

现在就可以了,可以自己拷贝看看效果。

互斥机制:QMutex, QMutexLocker, QSemaphore, QWaitCondition

oh天,简直就跟报菜名一样,这四个东西都是用来保证互斥机制的。分别对应了我们的std::mutex. std::mutex_guard, std::counting_semaphore和std::condition_variable四个东西。

关于锁等并发编程,这里笔者不打算重复说明了。笔者有一个专门讲述高级并发编程的模块,感兴趣的朋友可以看看:

高阶开发基础——目录部分-CSDN博客

一个简单的demo

#include <QCoreApplication>
#include <QDebug>
#include <QList>
#include <QMutex>
#include <QMutexLocker>
#include <QSemaphore>
#include <QThread>
#include <QWaitCondition>
​
const int      BufferSize = 5;         // 缓冲区大小
QList<int>     buffer;                 // 共享缓冲区
QMutex         mutex;                  // 用于保护共享缓冲区
QSemaphore     freeSpace(BufferSize);  // 空闲空间信号量
QSemaphore     usedSpace(0);           // 已使用空间信号量
QWaitCondition bufferNotEmpty;         // 缓冲区非空条件
QWaitCondition bufferNotFull;          // 缓冲区未满条件
​
// 生产者线程
class Producer : public QThread {
protected:void run() override {for (int i = 0; i < 10; ++i) {freeSpace.acquire();  // 等待空闲空间mutex.lock();         // 锁定互斥量
​// 如果缓冲区已满,等待缓冲区未满条件if (buffer.size() == BufferSize) {bufferNotFull.wait(&mutex);}
​buffer.append(i);  // 生产数据qDebug() << "Produced:" << i;
​mutex.unlock();       // 解锁互斥量usedSpace.release();  // 增加已使用空间
​// 通知消费者缓冲区非空bufferNotEmpty.wakeAll();}}
};
​
// 消费者线程
class Consumer : public QThread {
protected:void run() override {for (int i = 0; i < 10; ++i) {usedSpace.acquire();  // 等待已使用空间mutex.lock();         // 锁定互斥量
​// 如果缓冲区为空,等待缓冲区非空条件if (buffer.isEmpty()) {bufferNotEmpty.wait(&mutex);}
​int value = buffer.takeFirst();  // 消费数据qDebug() << "Consumed:" << value;
​mutex.unlock();       // 解锁互斥量freeSpace.release();  // 增加空闲空间
​// 通知生产者缓冲区未满bufferNotFull.wakeAll();}}
};
​
int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);
​Producer producer;Consumer consumer;
​producer.start();  // 启动生产者线程consumer.start();  // 启动消费者线程
​producer.wait();  // 等待生产者线程结束consumer.wait();  // 等待消费者线程结束
​return a.exec();
}

跨线程的通信

所以Qt如何完成跨线程的通信,即跨线程的信号与槽呢?答案是在使用QueueConnection,当然AutoConnection也可以,Qt6中会默认判断两个对象是否在同一个线程,不再的话就会自动选择QueueConnection。这个是将我们的信号与槽机制放置到了事件的监听循环队列当中去了。

#include <QCoreApplication>
#include <QDebug>
#include <QObject>
#include <QThread>
​
// 工作线程类
class Worker : public QObject {Q_OBJECT
​
public:explicit Worker(QObject *parent = nullptr) : QObject(parent) {}
​
public slots:void doWork() {qDebug() << "Worker: Running in thread" << QThread::currentThreadId();
​// 模拟耗时操作QThread::sleep(2);
​// 发送完成信号emit workDone();}
​
signals:void workDone();  // 工作完成信号
};
​
// 主线程类
class Controller : public QObject {Q_OBJECT
​
public:explicit Controller(QObject *parent = nullptr) : QObject(parent) {}
​void start() {qDebug() << "Controller: Running in thread"<< QThread::currentThreadId();
​// 创建工作线程QThread *workerThread = new QThread;Worker  *worker       = new Worker;
​// 将 Worker 移动到工作线程worker->moveToThread(workerThread);
​// 连接信号与槽connect(workerThread, &QThread::started, worker, &Worker::doWork);connect(worker, &Worker::workDone, this, &Controller::handleWorkDone);connect(worker, &Worker::workDone, workerThread, &QThread::quit);connect(workerThread, &QThread::finished, worker, &Worker::deleteLater);connect(workerThread, &QThread::finished, workerThread,&QThread::deleteLater);
​// 启动工作线程workerThread->start();}
​
public slots:void handleWorkDone() {qDebug() << "Controller: Work done, running in thread"<< QThread::currentThreadId();}
};
​
int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);
​Controller controller;controller.start();  // 启动控制器
​return a.exec();
}
​
#include "main.moc"
    1. 这里#include "main.moc"是一个小的偷懒技巧,QT的元对象是依赖于元对象处理器的,我们include进来qt处理后的结果才好方便解决未定义的符号问题

  • 2. Worker::workDone 信号是从工作线程发射的,而 Controller::handleWorkDone 槽是在主线程中执行的。

    1. 由于信号与槽的连接类型是 Qt::QueuedConnection(默认跨线程连接类型),信号会被放入主线程的事件循环中,由主线程异步执行槽函数。

入门QtConcurrent,Qt集成的一个并发框架

为什么会有QtConcorrent呢?因为大部分情况下,我们可以不需要太客制化的并发(特殊场景除外)。我们总是希望将任务并行化但是不想要关心其具体的细节。

QtConcurrent就将并发进一步的提升为了一个经典的异步框架。我们只需要让一个任务并发的执行出去,而不需要关心它如何执行,在另一个时间点上我调用一个wait机制就把东西取回来(如果已经做完了直接返回,没有做完那就阻塞的等待直到做完了为之)

返回值函数签名
QFuture<T>run(Function function, ...)
QFuture<T>run(QThreadPool *pool, Function function, ...)

这里,我们的Run就是直接的派发一个任务出去。返回回来的QFuture就是我们希望得到的一个结果。比如说,我们depatch了一个网络请求。需要其结果的时候,我们的结果就应该被存放在我们的QFuture里面。

直到我们获取的时候,我们才会获取我们想要的东西。我们调用的是waitForFinish这个函数,明确的表达我们需要结果后才会执行。

简单的说:QFuture 允许线程与一个或多个将在稍后某个时间点准备就绪的结果同步。结果可以是任何具有默认、复制和可能移动构造函数的类型。如果在调用 result()、resultAt()、results() 和 takeResult() 函数时结果不可用,QFuture 将等待,直到结果可用。您可以使用 isResultReadyAt() 函数来确定结果是否已准备就绪。对于报告多个结果的 QFuture 对象,resultCount() 函数返回连续结果的数量。这意味着从 0 到 resultCount() 迭代结果始终是安全的。takeResult() 会使未来无效,并且任何后续尝试访问未来结果的尝试都会导致未定义的行为。isValid() 告诉您是否可以访问结果。

QFuture 提供了 Java 样式的迭代器 (QFutureIterator) 和 STL 样式的迭代器 (QFuture::const_iterator)。使用这些迭代器是访问未来结果的另一种方式。

如果需要将一个异步计算的结果传递给另一个异步计算,QFuture 提供了一种使用 then() 链接多个顺序计算的便捷方法。onCanceled() 可用于添加在 QFuture 被取消时要调用的处理程序。此外,onFailed() 可用于处理链中发生的任何故障。请注意,QFuture 依赖于异常来进行错误处理。如果无法使用异常,您仍然可以通过将错误类型作为 QFuture 类型的一部分来指示 QFuture 的错误状态。例如,您可以使用 std::variant、std::any 或类似类型来保存结果或失败,或者创建自定义类型。

上面的部分是翻译Qt文档的结果。

如果需要使用到信号与槽的机制,我们还会需要使用的是QFutureWatcher来监控我们的QFuture的状态,这样,信号与槽机制就可以跟异步框架精密协调的工作起来了。

QFutureWatcher 中还提供了一些 QFuture 函数:progressValue()、progressMinimum()、progressMaximum()、progressText()、isStarted()、isFinished()、isRunning()、isCanceled()、isSuspending()、isSuspended()、waitForFinished()、result() 和 resultAt()。cancel()、setSuspended()、suspend()、resume() 和 toggleSuspended() 函数是 QFutureWatcher 中的插槽。 状态更改通过 started()、finished()、canceled()、suspending()、suspended()、resumed()、resultReadyAt() 和 resultsReadyAt() 信号报告。进度信息由 progressRangeChanged()、void progressValueChanged() 和 progressTextChanged() 信号提供。 节流控制由 setPendingResultsLimit() 函数提供。当待处理的 resultReadyAt() 或 resultsReadyAt() 信号的数量超过限制时,未来所代表的计算将自动受到限制。一旦待处理信号的数量低于限制,计算将恢复。

以及,Qt自身也提供了一个类似域LockGuard的机制,这里,我们的类名称是QFutureSynchronizer,可以看看这里的Qt文档。

一些参考

  • Qt 6 Core Advanced with C++ | Udemy

  • Qt Documentations Qt Documentation | All Documentation

相关文章:

系统讨论Qt的并发编程2——介绍一下Qt并发的一些常用的东西

目录 QThreadPool与QRunnable 互斥机制&#xff1a;QMutex, QMutexLocker, QSemaphore, QWaitCondition 跨线程的通信 入门QtConcurrent&#xff0c;Qt集成的一个并发框架 一些参考 QThreadPool与QRunnable QThreadPool自身预备了一些QThread。这样&#xff0c;我们就不需…...

【数据挖掘】Pandas之DataFrame

在 Pandas 中&#xff0c;DataFrame 提供了丰富的数据操作功能&#xff0c;包括 查询、编辑、分类和汇总。 1. 数据查询&#xff08;Filtering & Querying&#xff09; 1.1 按索引或列名查询 import pandas as pddata {"ID": [101, 102, 103, 104, 105],"…...

C++:volatile、const、mutable关键字

文章目录 volatile、const、mutable 关键字的作用、联系与区别 1️⃣ **volatile** —— 防止编译器优化&#xff0c;确保变量每次访问都从内存读取**作用****使用场景****示例** 2️⃣ **const** —— 限制变量的修改&#xff0c;保证不可变性**作用****使用场景****示例** 3️…...

linux离线安装miniconda环境

1 下载安装包 可以在官网下载最新版 https://www.anaconda.com/download/success#miniconda 或者在软件目录选择合适的版本 https://repo.anaconda.com/miniconda/ 安装包传入离线服务器 ./Miniconda3-py311_24.9.2-0-Linux-x86_64.sh2 运行安装包 ./Miniconda3-py311_24…...

考研408数据结构线性表核心知识点与易错点详解(附真题示例与避坑指南)

一、线性表基础概念 1.1 定义与分类 定义&#xff1a;线性表是由n&#xff08;n≥0&#xff09;个相同类型数据元素构成的有限序列&#xff0c;元素间呈线性关系。 分类&#xff1a; 顺序表&#xff1a;元素按逻辑顺序存储在一段连续的物理空间中&#xff08;数组实现&…...

selenium用例执行过程采集操作形成测试报告上的回复

在代码执行的过程中不断的进行截图&#xff0c;把截图拼接成gif动态图&#xff0c;放在测试报告上 1、每条用例执行启动一个线程&#xff0c;这个线程会每隔0.3秒进行截图 项目下创建一个临时目录video用来存储所有截图以及gif动态图封装不断截图的方法&#xff0c;每隔0.3秒…...

多元数据直观表示(R语言)

一、实验目的&#xff1a; 通过上机试验&#xff0c;掌握R语言实施数据预处理及简单统计分析中的一些基本运算技巧与分析方法&#xff0c;进一步加深对R语言简单统计分析与图形展示的理解。 数据&#xff1a; 链接: https://pan.baidu.com/s/1kMdUWXuGCfZC06lklO5iXA 提取码: …...

【JavaEE】线程安全

【JavaEE】线程安全 一、引出线程安全二、引发线程安全的原因三、解决线程安全问题3.1 synchronized关键字&#xff08;解决修改操作不是原子的&#xff09;3.1.1 synchronized的特性3.1.1 synchronized的使用事例 3.2 volatile 关键字&#xff08;解决内存可见性&#xff09; …...

HarmonyOS 5.0应用开发——多线程Worker和@Sendable的使用方法

【高心星出品】 文章目录 多线程Worker和Sendable的使用方法开发步骤运行结果 多线程Worker和Sendable的使用方法 Worker在HarmonyOS中提供了一种多线程的实现方式&#xff0c;它允许开发者在后台线程中执行长耗时任务&#xff0c;从而避免阻塞主线程并提高应用的响应性。 S…...

华为OD-2024年E卷-分批萨[100分]

文章目录 题目描述输入描述输出描述用例1解题思路Python3源码 题目描述 吃货"和"馋嘴"两人到披萨店点了一份铁盘&#xff08;圆形&#xff09;披萨&#xff0c;并嘱咐店员将披萨按放射状切成大小相同的偶数个小块。但是粗心的服务员将披萨切成了每块大小都完全不…...

SSH监控

创建/etc/ssh/sshrc文件 写入以命令 echo " 系统状态 " uptime free -h 每次登录会显示 如果在sshrc文件加入以下脚本每次登录就是执行这个脚本 # cat /etc/ssh/sshrc echo " 系统状态 " uptime free -h /usr/local/bin/monit.sh以…...

leetcode日记(74)扰乱字符串

很有难度的一题&#xff0c;一开始真的绕了很多思维上的弯路。 最开始的想法是递归&#xff0c;看到题目的时候想到动态规划但是完全没有思路应该怎么用&#xff0c;结果确实是递归动态规划。 最开始的想法是构建树&#xff0c;每一层包含这一步划分的方法&#xff08;实际会…...

RV1126的OSD模块和SDL_TTF结合输出H264文件

目录 一.RV1126多线程处理输出OSD字符叠加图层的流程 1.1. VI模块的初始化 1.2. 初始化VENC模块&#xff1a; 1.3. 初始化RGN模块&#xff1a; 1.4. 绑定VI模块和VENC模块&#xff0c;伪代码如下 1.5. 创建多线程进行OSD字库的叠加&#xff1a; 1.6. 获取每一帧处理过后的…...

GEE:计算长时间序列NPP与NDVI之间的相关系数

GEE中内置了计算相关系数的函数&#xff0c;可以分析两个变量之间的相关性&#xff0c;比如要分析两个波段之间的相关性&#xff0c;主要用到ee.Reducer.pearsonsCorrelation()函数。 ee.Reducer.pearsonsCorrelation() 内容&#xff1a;创建一个双输入归约器&#xff0c;用于…...

水仙花数(华为OD)

题目描述 所谓水仙花数&#xff0c;是指一个n位的正整数&#xff0c;其各位数字的n次方和等于该数本身。 例如153是水仙花数&#xff0c;153是一个3位数&#xff0c;并且153 13 53 33。 输入描述 第一行输入一个整数n&#xff0c;表示一个n位的正整数。n在3到7之间&#x…...

【对话状态跟踪】关心整个对话过程用户完整意图变化

对话状态管理器 核心逻辑是解决键冲突和验证范围有效性&#xff0c; 但需依赖外部输入的正确性。在实际应用中&#xff0c; 可能需要结合用户提示或自动修正逻辑以提高鲁棒性。 NLU 槽 值 对儿 NLU的目的是把自然语言解析成结构化语义。结构化语义有多种表示方式&#xff0c…...

【分享】网间数据摆渡系统,如何打破传输瓶颈,实现安全流转?

在数字化浪潮中&#xff0c;企业对数据安全愈发重视&#xff0c;网络隔离成为保护核心数据的重要手段。内外网隔离、办公网与研发网隔离等措施&#xff0c;虽为数据筑牢了防线&#xff0c;却也给数据传输带来了诸多难题。传统的数据传输方式在安全性、效率、管理等方面暴露出明…...

TikTok创作者市场关闭!全新平台TikTok One将带来哪些改变?

TikTok创作者市场关闭&#xff0c;全新平台TikTok One上线&#xff0c;创作者和品牌将迎来哪些新机遇&#xff1f; 近日&#xff0c;TikTok宣布关闭其原有的创作者市场&#xff08;TikTok Creator Marketplace&#xff09;&#xff0c;并推出全新平台TikTok One。这一消息在社…...

LeetCode hot 100—矩阵置零

题目 给定一个 m x n 的矩阵&#xff0c;如果一个元素为 0 &#xff0c;则将其所在行和列的所有元素都设为 0 。请使用 原地 算法。 示例 示例 1&#xff1a; 输入&#xff1a;matrix [[1,1,1],[1,0,1],[1,1,1]] 输出&#xff1a;[[1,0,1],[0,0,0],[1,0,1]]示例 2&#xff1…...

部署Windows Server自带“工作文件夹”实现企业网盘功能完整步骤

前文已经讲解过Windows Server自带的“工作文件夹”功能&#xff0c;现以Windows Server 2025为例介绍部署工作文件夹的完整步骤&#xff1a; 为了确保您能够顺利部署和充分利用工作文件夹的功能&#xff0c;我将按照以下步骤进行讲解。 请注意&#xff0c;在域环境中部署工作…...

【分享】推荐一些办公小工具

1、PDF 在线转换 https://smallpdf.com/cn/pdf-tools 推荐理由&#xff1a;大部分的转换软件需要收费&#xff0c;要么功能不齐全&#xff0c;而开会员又用不了几次浪费钱&#xff0c;借用别人的又不安全。 这个网站它不需要登录或下载安装。而且提供的免费功能就能满足日常…...

现有的 Redis 分布式锁库(如 Redisson)提供了哪些便利?

现有的 Redis 分布式锁库&#xff08;如 Redisson&#xff09;相比于开发者自己基于 Redis 命令&#xff08;如 SETNX, EXPIRE, DEL&#xff09;手动实现分布式锁&#xff0c;提供了巨大的便利性和健壮性。主要体现在以下几个方面&#xff1a; 原子性保证 (Atomicity)&#xff…...

【C++进阶篇】智能指针

C内存管理终极指南&#xff1a;智能指针从入门到源码剖析 一. 智能指针1.1 auto_ptr1.2 unique_ptr1.3 shared_ptr1.4 make_shared 二. 原理三. shared_ptr循环引用问题三. 线程安全问题四. 内存泄漏4.1 什么是内存泄漏4.2 危害4.3 避免内存泄漏 五. 最后 一. 智能指针 智能指…...

Web中间件--tomcat学习

Web中间件–tomcat Java虚拟机详解 什么是JAVA虚拟机 Java虚拟机是一个抽象的计算机&#xff0c;它可以执行Java字节码。Java虚拟机是Java平台的一部分&#xff0c;Java平台由Java语言、Java API和Java虚拟机组成。Java虚拟机的主要作用是将Java字节码转换为机器代码&#x…...

【MATLAB代码】基于最大相关熵准则(MCC)的三维鲁棒卡尔曼滤波算法(MCC-KF),附源代码|订阅专栏后可直接查看

文章所述的代码实现了基于最大相关熵准则(MCC)的三维鲁棒卡尔曼滤波算法(MCC-KF),针对传感器观测数据中存在的脉冲型异常噪声问题,通过非线性加权机制提升滤波器的抗干扰能力。代码通过对比传统KF与MCC-KF在含异常值场景下的表现,验证了后者在状态估计鲁棒性方面的显著优…...

代码规范和架构【立芯理论一】(2025.06.08)

1、代码规范的目标 代码简洁精炼、美观&#xff0c;可持续性好高效率高复用&#xff0c;可移植性好高内聚&#xff0c;低耦合没有冗余规范性&#xff0c;代码有规可循&#xff0c;可以看出自己当时的思考过程特殊排版&#xff0c;特殊语法&#xff0c;特殊指令&#xff0c;必须…...

关于uniapp展示PDF的解决方案

在 UniApp 的 H5 环境中使用 pdf-vue3 组件可以实现完整的 PDF 预览功能。以下是详细实现步骤和注意事项&#xff1a; 一、安装依赖 安装 pdf-vue3 和 PDF.js 核心库&#xff1a; npm install pdf-vue3 pdfjs-dist二、基本使用示例 <template><view class"con…...

Rust 开发环境搭建

环境搭建 1、开发工具RustRover 或者vs code 2、Cygwin64 安装 https://cygwin.com/install.html 在工具终端执行&#xff1a; rustup toolchain install stable-x86_64-pc-windows-gnu rustup default stable-x86_64-pc-windows-gnu ​ 2、Hello World fn main() { println…...

Vue ③-生命周期 || 脚手架

生命周期 思考&#xff1a;什么时候可以发送初始化渲染请求&#xff1f;&#xff08;越早越好&#xff09; 什么时候可以开始操作dom&#xff1f;&#xff08;至少dom得渲染出来&#xff09; Vue生命周期&#xff1a; 一个Vue实例从 创建 到 销毁 的整个过程。 生命周期四个…...

如何配置一个sql server使得其它用户可以通过excel odbc获取数据

要让其他用户通过 Excel 使用 ODBC 连接到 SQL Server 获取数据&#xff0c;你需要完成以下配置步骤&#xff1a; ✅ 一、在 SQL Server 端配置&#xff08;服务器设置&#xff09; 1. 启用 TCP/IP 协议 打开 “SQL Server 配置管理器”。导航到&#xff1a;SQL Server 网络配…...