【QT进阶】Qt线程与并发之QtConcurrent返回值与run方法的参数说明

本文主要是介绍【QT进阶】Qt线程与并发之QtConcurrent返回值与run方法的参数说明,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

往期回顾

【QT进阶】Qt线程与并发之线程和并发的简单介绍-CSDN博客

【QT进阶】Qt线程与并发之创建线程的三种方法(超详细介绍)-CSDN博客

【QT进阶】Qt线程与并发之QtConcurrent的简单介绍-CSDN博客

 【QT进阶】Qt线程与并发之QtConcurrent返回值与run方法的参数说明

一、QtConcurrent::run的参数说明

QtConcurrent::run函数的参数类型是模板化的,它可以接受任意可调用对象(函数指针、成员函数指针、函数对象、Lambda表达式等)作为参数。这意味着我们可以传递任何可调用对象作为要在后台线程中执行的任务。

1、QtConcurrent::run函数的签名

template <typename T>
QFuture<T> QtConcurrent::run(T (*functionPointer)(), ...);

这里的T是任务函数的返回类型。我们可以传递一个普通的函数指针,然后在后台线程中执行该函数。除了普通的函数指针外,我们还可以传递其他可调用对象,只要它们符合函数签名的要求即可。

我们看几个参数示例

 2、参数示例

QtConcurrent::run函数的参数,可以是全局函数,也可以是类成员函数,还可以是lambda表达式,同时还可以是不带参数的。

1、类成员函数做run参数

intnum1=0;
int num2 = 0;
QFuture<int> future = QtConcrrent::run(this, &MainWindow::timeTask, num1, num2);

2、用全局函数做参数 

static int timeTask()
int i= 0;
while(i < 123456789)
{
QFuture<int> future = QtConcurrent::run(timeTask);
i++;
}
return i;

3、lambda表达式做参数 

// 在后台线程中执行Lambda表达式
QFuture<int> future = QtConcurrent::run([](){// 执行一些操作return result;
});

对比一下,首先run方法里是可以带参数的,其次,如果是用类成员函数做参数,是需要添加this并以类名引导,但是如果是用全局函数做参数,则都不用加,直接放函数名就可以了。

二、获取QtConcurrent的返回值 

1、获取方式

获取QtConcurrent的结果,需要使用QFutureWatcher类,链接它的信号finished,然后给watcher设置future,当监控到future执行结束后,可以获取它的执行结果,调用的是result()函数:

qDebug() << "return = " << watcher->result();

2、执行过程

 2.1、创建QFutureWatcher对象

创建一个 QFutureWatcher 对象,用于监视 QFuture 对象的执行状态。

    QFutureWatcher<int>* fw = new QFutureWatcher<int>;
2.2、执行 成员函数 timeTask

在一个新线程中执行 ch74 类的成员函数 timeTask,并传递 num01 和 num02 作为参数。 

    QFuture<int> ft = QtConcurrent::run(this, &ch74::timeTask, num01, num02);
2.3、关联QFuture<int> 对象

将 QFuture<int> 对象与 QFutureWatcher 相关联,以便监视其执行状态。 

fw->setFuture(ft);
2.4、连接 finished信号

连接 QFutureWatcher 的 finished信号,由于给watcher设置future,当监控到future执行结束后,可以获取它的执行结果,调用的是result()函数: 

    connect(fw, &QFutureWatcher<int>::finished, [&]{qDebug() << "QFutureWatcher finished";qDebug() << "result = " << fw->result();//qDebug() << "num1 = " << num1;//qDebug() << "num2 = " << num2;});
2.5、循环处理事件

通过循环处理事件来保持界面的响应性,直到 QFuture 执行完成。

    //没完成的时候循环处理事件来保持界面的响应性while (!ft.isFinished()){QApplication::processEvents(QEventLoop::AllEvents, 30);}

QApplication::processEvents

函数用于处理事件循环中的事件,确保界面的响应性。调用该函数会处理当前事件队列中的所有事件,直到事件队列为空或者达到指定的最大处理时间。 

QEventLoop::AllEvents

参数表示处理所有类型的事件,包括用户输入事件、定时器事件、绘图事件等。

30 参数表示最大处理时间为30毫秒,即函数最多处理30毫秒的事件后返回。这样可以避免在处理事件的过程中阻塞主线程过长时间,确保界面的及时响应。

3、最终代码

#include "ch74.h"
#include <QDebug>
#include <QtConcurrent>
#include <QFuture>
#include <QFutureWatcher>ch74::ch74(QWidget *parent): QWidget(parent)
{ui.setupUi(this);
}ch74::~ch74()
{}int ch74::timeTask(int& num1, int& num2)
{for (int i = 0; i < 1000; i++){num1++;num2++;qDebug() << num1;qDebug() << num2;}return num1 + num2;
}void ch74::on_pushButton_clicked()
{int num01 = 0;int num02 = 0;//创建 QFutureWatcher 对象,用于监视一个 QFuture 对象的执行状态QFutureWatcher<int>* fw = new QFutureWatcher<int>;//通过 QtConcurrent::run 函数在一个新线程中执行 ch74 类的成员函数 timeTask.(并发)// num01 和 num02 作为参数传递给 timeTask 函数。QFuture<int> ft = QtConcurrent::run(this, &ch74::timeTask, num01, num02);//通过 fw->setFuture(ft) 将 QFuture<int> 对象与 QFutureWatcher 相关联,//这样 QFutureWatcher 就能监视 QFuture 对象的执行状态fw->setFuture(ft);//连接 QFutureWatcher 的 finished 信号,当 QFuture 执行完成时输出调试信息,注意这里由于捕获的是指针fw
//所以lambda表达式里用的是[&]而不是[=]connect(fw, &QFutureWatcher<int>::finished, [&] {qDebug() << "QFutureWatcher finished";qDebug() << "result = " << fw->result();//qDebug() << "num1 = " << num1;//qDebug() << "num2 = " << num2;});//没完成的时候循环处理事件来保持界面的响应性while (!ft.isFinished()){//QApplication::processEvents 函数用于处理事件循环中的事件,确保界面的响应性//调用该函数会处理当前事件队列中的所有事件,直到事件队列为空或者达到指定的最大处理时间QApplication::processEvents(QEventLoop::AllEvents, 30);}
}

以上就是QtConcurrent返回值与run方法的参数说明的简单介绍

都看到这里了,点个赞再走呗朋友~

加油吧,预祝大家变得更强!

这篇关于【QT进阶】Qt线程与并发之QtConcurrent返回值与run方法的参数说明的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/937352

相关文章

Linux线程同步/互斥过程详解

《Linux线程同步/互斥过程详解》文章讲解多线程并发访问导致竞态条件,需通过互斥锁、原子操作和条件变量实现线程安全与同步,分析死锁条件及避免方法,并介绍RAII封装技术提升资源管理效率... 目录01. 资源共享问题1.1 多线程并发访问1.2 临界区与临界资源1.3 锁的引入02. 多线程案例2.1 为

Python安装Pandas库的两种方法

《Python安装Pandas库的两种方法》本文介绍了三种安装PythonPandas库的方法,通过cmd命令行安装并解决版本冲突,手动下载whl文件安装,更换国内镜像源加速下载,最后建议用pipli... 目录方法一:cmd命令行执行pip install pandas方法二:找到pandas下载库,然后

Linux系统中查询JDK安装目录的几种常用方法

《Linux系统中查询JDK安装目录的几种常用方法》:本文主要介绍Linux系统中查询JDK安装目录的几种常用方法,方法分别是通过update-alternatives、Java命令、环境变量及目... 目录方法 1:通过update-alternatives查询(推荐)方法 2:检查所有已安装的 JDK方

SQL Server安装时候没有中文选项的解决方法

《SQLServer安装时候没有中文选项的解决方法》用户安装SQLServer时界面全英文,无中文选项,通过修改安装设置中的国家或地区为中文中国,重启安装程序后界面恢复中文,解决了问题,对SQLSe... 你是不是在安装SQL Server时候发现安装界面和别人不同,并且无论如何都没有中文选项?这个问题也

Java Thread中join方法使用举例详解

《JavaThread中join方法使用举例详解》JavaThread中join()方法主要是让调用改方法的thread完成run方法里面的东西后,在执行join()方法后面的代码,这篇文章主要介绍... 目录前言1.join()方法的定义和作用2.join()方法的三个重载版本3.join()方法的工作原

C语言进阶(预处理命令详解)

《C语言进阶(预处理命令详解)》文章讲解了宏定义规范、头文件包含方式及条件编译应用,强调带参宏需加括号避免计算错误,头文件应声明函数原型以便主函数调用,条件编译通过宏定义控制代码编译,适用于测试与模块... 目录1.宏定义1.1不带参宏1.2带参宏2.头文件的包含2.1头文件中的内容2.2工程结构3.条件编

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

java如何实现高并发场景下三级缓存的数据一致性

《java如何实现高并发场景下三级缓存的数据一致性》这篇文章主要为大家详细介绍了java如何实现高并发场景下三级缓存的数据一致性,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 下面代码是一个使用Java和Redisson实现的三级缓存服务,主要功能包括:1.缓存结构:本地缓存:使

在MySQL中实现冷热数据分离的方法及使用场景底层原理解析

《在MySQL中实现冷热数据分离的方法及使用场景底层原理解析》MySQL冷热数据分离通过分表/分区策略、数据归档和索引优化,将频繁访问的热数据与冷数据分开存储,提升查询效率并降低存储成本,适用于高并发... 目录实现冷热数据分离1. 分表策略2. 使用分区表3. 数据归档与迁移在mysql中实现冷热数据分