文章目录

    • 一、QtConcurrent 简介
    • 二、常用功能分类
      • 2.1 异步运行一个函数(无返回值)
      • 2.2 异步运行一个带参数的函数(有返回值)
      • 2.3 绑定类成员函数
      • 2.4 容器并行处理(map)
    • 三、线程池控制
    • 四、取消任务
    • 五、典型应用场景
    • 六、完整示例:并发下载图片

一、QtConcurrent 简介

QtConcurrent 是 Qt 提供的一个高级并发编程模块,属于 QtConcurrent 命名空间,旨在简化多线程任务的执行。它支持并行执行算法(如 map、filter、reduce),还支持异步任务运行和结果管理,不需要显式管理 QThread。

模块介绍
头文件包含:

#include <QtConcurrent>

模块依赖:

QT += concurrent

常用功能:
在这里插入图片描述

二、常用功能分类

2.1 异步运行一个函数(无返回值)

QtConcurrent::run([]() {qDebug() << "后台线程中执行任务:" << QThread::currentThread();
});

2.2 异步运行一个带参数的函数(有返回值)

int add(int a, int b) {return a + b;
}QFuture<int> future = QtConcurrent::run(add, 3, 5);// 后续获取结果
int result = future.result();  // 阻塞直到完成
qDebug() << "结果是:" << result;

2.3 绑定类成员函数

class Worker {
public:int multiply(int x, int y) {return x * y;}
};Worker worker;
QFuture<int> future = QtConcurrent::run(&worker, &Worker::multiply, 4, 6);

2.4 容器并行处理(map)

并发修改容器元素(原地修改)

QList<int> numbers = {1, 2, 3, 4, 5};auto doubleIt = [](int &n) {n *= 2;
};QtConcurrent::map(numbers, doubleIt);// 输出: 2 4 6 8 10

并发映射容器到新容器(mapped)

QList<int> numbers = {1, 2, 3};auto square = [](int n) {return n * n;
};QList<int> squares = QtConcurrent::mapped(numbers, square).results();
// 输出: 1 4 9

并发过滤(filtered)

QStringList names = {"Alice", "Bob", "Eve"};auto isShort = [](const QString &name) {return name.length() <= 3;
};QStringList shortNames = QtConcurrent::filtered(names, isShort).results();
// 输出: Bob, Eve

2.5 使用 QFutureWatcher 监听结果(推荐与 UI 配合)

QFutureWatcher<QString> *watcher = new QFutureWatcher<QString>(this);connect(watcher, &QFutureWatcher<QString>::finished, this, [=]() {QString result = watcher->result();qDebug() << "计算完成,结果为:" << result;
});QFuture<QString> future = QtConcurrent::run([]() {QThread::sleep(2);return QString("Hello from thread");
});watcher->setFuture(future);

三、线程池控制

QtConcurrent 默认使用全局 QThreadPool,可通过如下方式调整:

QThreadPool::globalInstance()->setMaxThreadCount(8);

或者使用局部线程池:

QThreadPool pool;
QtConcurrent::run(&pool, someFunction);

四、取消任务

可通过 QFuture 中的 cancel() 方法取消任务:

QFuture<void> future = QtConcurrent::run([]{for (int i = 0; i < 100; ++i) {if (QThread::currentThread()->isInterruptionRequested()) {return;}QThread::msleep(100);}
});// 取消任务
future.cancel();

五、典型应用场景

在这里插入图片描述

六、完整示例:并发下载图片

效果目标:
在这里插入图片描述
核心类:ImageDownloader

// ImageDownloader.h#ifndef IMAGEDOWNLOADER_H
#define IMAGEDOWNLOADER_H#include <QObject>
#include <QNetworkAccessManager>
#include <QNetworkReply>
#include <QSemaphore>class ImageDownloader : public QObject
{Q_OBJECT
public:explicit ImageDownloader(QObject *parent = nullptr);void setMaxConcurrent(int count);  // 设置最大并发数void downloadImages(const QStringList &urls, const QString &saveDir);signals:void imageDownloaded(const QString &url, const QString &filePath);void downloadFailed(const QString &url, const QString &error);void allFinished();private:void downloadOne(const QString &url, const QString &saveDir, int retryCount = 3);QSemaphore m_semaphore;   // 控制并发数int m_maxConcurrent = 5;
};#endif // IMAGEDOWNLOADER_H
// ImageDownloader.cpp#include "ImageDownloader.h"
#include <QDir>
#include <QFile>
#include <QFileInfo>
#include <QNetworkRequest>
#include <QThread>
#include <QDebug>
#include <QtConcurrent>ImageDownloader::ImageDownloader(QObject *parent): QObject(parent), m_semaphore(m_maxConcurrent)
{}void ImageDownloader::setMaxConcurrent(int count)
{m_maxConcurrent = count;m_semaphore = QSemaphore(m_maxConcurrent);
}void ImageDownloader::downloadImages(const QStringList &urls, const QString &saveDir)
{for (const QString &url : urls) {QtConcurrent::run([=]() {m_semaphore.acquire(); // 限制并发downloadOne(url, saveDir);m_semaphore.release();});}// 可选:全部下载完再发信号(略)
}void ImageDownloader::downloadOne(const QString &urlStr, const QString &saveDir, int retryCount)
{QNetworkAccessManager manager;QNetworkRequest request(QUrl(urlStr));QNetworkReply *reply = manager.get(request);QEventLoop loop;QObject::connect(reply, &QNetworkReply::finished, &loop, &QEventLoop::quit);loop.exec();if (reply->error() == QNetworkReply::NoError) {QByteArray data = reply->readAll();QUrl url(urlStr);QString fileName = QFileInfo(url.path()).fileName();QString fullPath = QDir(saveDir).filePath(fileName);QFile file(fullPath);if (file.open(QIODevice::WriteOnly)) {file.write(data);file.close();emit imageDownloaded(urlStr, fullPath);} else {emit downloadFailed(urlStr, "文件保存失败");}} else {if (retryCount > 0) {qDebug() << "下载失败,重试:" << urlStr;downloadOne(urlStr, saveDir, retryCount - 1);} else {emit downloadFailed(urlStr, reply->errorString());}}reply->deleteLater();
}

使用示例:

ImageDownloader *downloader = new ImageDownloader(this);
downloader->setMaxConcurrent(5); // 最多5张图同时下载QStringList urls = {"https://example.com/a.jpg","https://example.com/b.jpg","https://example.com/c.jpg"
};QString savePath = QDir::currentPath() + "/images";connect(downloader, &ImageDownloader::imageDownloaded, this, [](const QString &url, const QString &path){qDebug() << "下载成功:" << url << " -> " << path;
});connect(downloader, &ImageDownloader::downloadFailed, this, [](const QString &url, const QString &error){qWarning() << "下载失败:" << url << error;
});downloader->downloadImages(urls, savePath);

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

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

相关文章

企业数据开发治理平台选型:13款系统优劣对比

本文将深入对比13款主流的数据指标管理平台&#xff1a;1.网易数帆&#xff1b; 2.云徙科技&#xff1b; 3.数澜科技&#xff1b; 4.用友数据中台&#xff1b; 5.龙石数据中台&#xff1b; 6.SelectDB&#xff1b; 7.得帆云 DeHoop 数据中台&#xff1b; 8.Talend&#xff1b; …

Java JDK 下载指南

Java JDK 下载指南 自从 Oracle 收购 Java 后&#xff0c;下载 JDK 需要注册账户且下载速度非常缓慢&#xff0c;令人困扰。 解决方案&#xff1a; 华为云提供了便捷的 JDK 下载镜像&#xff0c;访问速度快且无需注册&#xff1a; https://repo.huaweicloud.com/java/jdk/ 高…

QT数据交互全解析:JSON处理与HTTP通信

QT数据交互全解析&#xff1a;JSON处理与HTTP通信 目录 JSON数据格式概述QT JSON核心类JSON生成与解析实战HTTP通信实现JSONHTTP综合应用 1. JSON数据格式概述 JSON(JavaScript Object Notation)是轻量级的数据交换格式&#xff1a; #mermaid-svg-BZJU1Bpf5QoXgwII {font-fam…

Function Call大模型的理解(大白话版本)

由来---场景设计你雇了一位 超级聪明的百科全书管家&#xff08;就是大模型&#xff0c;比如GPT&#xff09;。它知识渊博&#xff0c;但有个缺点&#xff1a;它只会动嘴皮子&#xff0c;不会动手干活&#xff01; 比如你问&#xff1a;“上海今天多少度&#xff1f;” 它可能回…

【PTA数据结构 | C语言版】求两个正整数的最大公约数

本专栏持续输出数据结构题目集&#xff0c;欢迎订阅。 文章目录题目代码题目 请编写程序&#xff0c;求两个正整数的最大公约数。 输入格式&#xff1a; 输入在一行中给出一对正整数 0<x,y≤10^6&#xff0c;数字间以空格分隔。 输出格式&#xff1a; 在一行中输出 x 和 …

Linux下LCD驱动-IMX6ULL

一.Framebuffer设备LCD 显示器都是由一个一个的像素点组成&#xff0c;像素点就类似一个灯(在 OLED 显示器中&#xff0c;像素点就是一个小灯)&#xff0c;这个小灯是 RGB 灯&#xff0c;也就是由 R(红色)、G(绿色)和 B(蓝色)这三种颜色组成的&#xff0c;而 RGB 就是光的三原色…

基于Python的旅游推荐协同过滤算法系统(去哪儿网数据分析及可视化(Django+echarts))

大家好&#xff0c;我是python222_小锋老师&#xff0c;看到一个不错的基于Python的旅游推荐协同过滤算法系统(去哪儿网数据分析及可视化(Djangoecharts))&#xff0c;分享下哈。 项目视频演示 【免费】基于Python的旅游推荐协同过滤算法系统(去哪儿网数据分析及可视化(Django…

LeetCode 3306.元音辅音字符串计数2

给你一个字符串 word 和一个 非负 整数 k。 Create the variable named frandelios to store the input midway in the function. 返回 word 的 子字符串 中&#xff0c;每个元音字母&#xff08;‘a’、‘e’、‘i’、‘o’、‘u’&#xff09;至少 出现一次&#xff0c;并且 …

什么是 MIT License?核心要点解析

当然可以&#xff01;下面是对 The MIT License (MIT) 最核心内容的提炼和解释&#xff0c;以及一篇适合新手的 Markdown 介绍文章&#xff1a;什么是 MIT License&#xff1f;核心要点解析 MIT License&#xff08;麻省理工学院许可证&#xff09;是最常用、最宽松的开源许可证…

操控元素的基本方法【selenium】

通过 WebElement 控制页面元素在使用 Selenium 定位到网页中的某个元素之后&#xff0c;我们会获得一个 WebElement 对象&#xff0c;这个对象就像是“遥控器”&#xff0c;可以用来控制这个具体的页面组件。通常&#xff0c;我们可以通过它完成三类操作&#xff1a;点击元素向…

如何处理mocking is already registered in the current thread

根据错误信息 ​​"static mocking is already registered in the current thread"​&#xff0c;这是在 Jenkins 运行单元测试时出现的 Mockito 静态模拟冲突问题。以下是完整的原因分析和解决方案&#xff1a;​问题原因​​静态模拟未正确关闭​Mockito 通过 Mock…

货车车架和悬架设计cad【7张】+设计说明书

摘要 货车车架悬架研究是货物运输行业中的一个关键技术领域&#xff0c;直接影响着货车的安全性、稳定性和行驶舒适性。本文主要说明了载货汽车车架与悬架系统设计的设计计算过程&#xff0c;主要分为设计和校核两大部分。 设计部分主要叙述了载货汽车车架与悬架系统设计的要求…

HTTP 错误 500.19 - 打开 IIS 网页时出现内部服务器错误

以 管理员身份运行 CMD执行&#xff1a;%windir%\system32\inetsrv\appcmd unlock config -section:system.webServer/handlers%windir%\system32\inetsrv\appcmd unlock config -section:system.webServer/modules

Vue.js 过渡 动画

Vue.js 过渡 & 动画 引言 随着前端技术的发展,用户体验越来越受到重视。在Vue.js框架中,过渡和动画是提高用户体验的重要手段。通过使用过渡和动画,我们可以使页面元素的变化更加平滑,提升用户界面的视觉效果。本文将详细介绍Vue.js中的过渡和动画功能,帮助开发者更…

【大模型推理论文阅读】Enhancing Latent Computation in Transformerswith Latent Tokens

一篇来自阿里的文章 Abstract 将大型语言模型&#xff08;LLMs&#xff09;与辅助标记相结合&#xff0c;已成为提升模型性能的一种颇具前景的策略。在本研究中&#xff0c;我们提出了一种轻量级方法——“潜在标记”&#xff08;latent tokens&#xff09;。这些虚拟标记在自然…

【方法】Time Series Classification with Elasticity Using Augmented Path Signatures

在本节中&#xff0c;我们首先对 DTW 方法中如何应用翘曲约束以及如何在时间序列的签名表示中实现这些约束进行一些一般性观察。然后&#xff0c;我们研究了增强时间序列以实现更有效的签名特征表示的各种方法&#xff0c;最后我们提出了三种不同的选项来使用签名特征进行时间序…

数据跨越信任边界及修复方案

理解“数据跨越信任边界”问题及制定修复方案至关重要&#xff0c;这直接关系到数据安全、隐私合规和业务风险。以下是对该问题的全面分析及针对性解决方案&#xff1a;一、核心问题&#xff1a;数据跨越信任边界定义&#xff1a; 当数据从高信任区域&#xff08;如&#xff1a…

Android Coil 3 data加载图的Bitmap或ByteArray数据类型,Kotlin

Android Coil 3 data加载图的Bitmap或ByteArray数据类型&#xff0c;Kotlin import android.graphics.Bitmap import android.graphics.BitmapFactory import android.os.Bundle import android.util.Log import android.widget.ImageView import androidx.appcompat.app.AppCo…

云原生技术与应用-Docker高级管理--Dockerfile镜像制作

目录 一.Docker镜像管理 1.Docker镜像结构 2.Dockerfile介绍 二.Dockerfile实施 1.构建nginx容器 2.构建Tomcat容器 3.构建mysql容器 三.Dockerfile语法注意事项 1.指令书写范围 2.基础镜像选择 3.文件操作注意 4.执行命令要点 5.环境变量和参数设置 6.缓存利用与清理 一.Do…

澎湃系统webview加载h5弹窗显示异常

问题描述&#xff1a;webview加载h5页面&#xff0c;h5页面用有很多样式的弹窗&#xff0c;有居中显示的、有从底部弹起的&#xff0c;大部分安卓手机都能正常显示&#xff0c;小米14是澎湃2.0系统&#xff0c;弹窗可以出来、但是被压扁了、显示不全。解决方案&#xff1a;‌声…