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

Qt开发:QtConcurrent介绍和使用

文章目录

    • 一、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.dtcms.com/a/273128.html

相关文章:

  • Python正则表达式实战指南
  • 深度学习13(经典卷积网络结构+卷积网络结构优化)
  • J1939协议
  • 个体户核定多地暂停,将不再享受核定征收?
  • 人工智能-基础篇-29-什么是低代码平台?
  • 大数据学习6:Sqoop数据迁移工具
  • ArcGIS 打开 nc 降雨量文件
  • MinerU2将PDF转成md文件,并分拣图片
  • TB6612电机驱动
  • [注解: @ComponentScan]-原理分析
  • Cloudflare 发布容器服务公测版:边缘计算新时代来临?
  • 职坐标:嵌入式AI边缘计算实战
  • React 实现五子棋人机对战小游戏
  • FFmpeg Windows安装
  • 定位模拟的详细步骤
  • vue3使用mermaid生成图表,并可编辑
  • 数学建模:多目标规划:ε约束法、 理想点法
  • 【大模型推理论文阅读】Enhancing Latent Computation in Transformerswith Latent Tokens
  • pharokka phold--快速噬菌体注释工具
  • 深入了解 Vim 编辑器:从入门到精通
  • MySQL高级特性全面解析:约束、表关系、多表查询与事务
  • 深入剖析C++ RPC框架原理:有栈协程与分布式系统设计
  • 技术学习_检索增强生成(RAG)
  • QT数据交互全解析:JSON处理与HTTP通信
  • 云原生技术与应用-Docker高级管理--Dockerfile镜像制作
  • 西部数据WD授权代理商-深圳同袍存储科技有限公司
  • 医学+AI!湖北中医药大学信息工程学院与和鲸科技签约101数智领航计划
  • Web后端开发工程师AI协作指南
  • 龙迅#LT7911E适用于TPYE-C/DP/EDP转MIPIDSI/LVDS应用功能,支持DSC 分辨率缩放,分辨率高达4K60HZ!
  • 寒武纪MLU370编程陷阱:float32精度丢失的硬件级解决方案——混合精度训练中的定点数补偿算法设计