qt-C++笔记之使用QtConcurrent异步地执行槽函数中的内容,使其不阻塞主界面

qt-C++笔记之使用QtConcurrent异步地执行槽函数中的内容,使其不阻塞主界面

code review!

文章目录

  • qt-C++笔记之使用QtConcurrent异步地执行槽函数中的内容,使其不阻塞主界面
    • 1.QtConcurrent::run基本用法
      • 基本用法
        • 启动一个全局函数或静态成员函数
        • 使用 Lambda 表达式
        • 启动类的成员函数
      • 指定执行的线程
      • 使用返回值
      • 注意事项
    • 2.代码1:槽函数定义——>QtConcurrent::run(Lambda表达式)——>全局函数
    • 3.代码2:槽函数定义——>QtConcurrent::run(Lambda表达式)——>全局函数
    • 4.代码3:槽函数定义——>QtConcurrent::run(this,&类名::成员函数)
    • 5.代码4:槽函数定义——>QtConcurrent::run(Lambda表达式[this]{执行内容})
    • 6.上述例程的test.pro

1.QtConcurrent::run基本用法

QtConcurrent::run 是 Qt 框架中一个非常有用的函数,用于在不同的线程中异步执行函数或者成员函数,这样可以避免阻塞主线程,提高应用程序的响应性。这个函数是 Qt 并发编程模块的一部分,使用前需要包含头文件 <QtConcurrent>

基本用法

QtConcurrent::run 可以启动任何可调用的对象,包括普通函数、类成员函数以及 lambda 表达式。它返回一个 QFuture<T> 对象,你可以使用这个对象来查询任务的状态或结果。

启动一个全局函数或静态成员函数
#include <QtConcurrent>

void myFunction(int arg1, double arg2) {
    // 处理函数
}

int main() {
    QFuture<void> future = QtConcurrent::run(myFunction, 1, 2.0);
}
使用 Lambda 表达式
#include <QtConcurrent>

int main() {
    auto lambda = [] (int value) {
        // 一些处理
    };
    QFuture<void> future = QtConcurrent::run(lambda, 42);
}
启动类的成员函数
#include <QtConcurrent>

class MyClass {
public:
    void myMemberFunction(int arg) {
        // 处理函数
    }
};

int main() {
    MyClass myObject;
    QFuture<void> future = QtConcurrent::run(&MyClass::myMemberFunction, &myObject, 123);
}

指定执行的线程

默认情况下,QtConcurrent::run 使用全局线程池来执行任务。但是,你也可以指定一个自定义的 QThreadPool 来运行任务。

#include <QtConcurrent>

void myFunction() {
    // 函数实现
}

int main() {
    QThreadPool pool;
    pool.setMaxThreadCount(2);  // 设置线程池大小

    QFuture<void> future = QtConcurrent::run(&pool, myFunction);
    future.waitForFinished();  // 等待任务完成
}

使用返回值

如果被调用的函数有返回值,你可以通过 QFuture<T> 来获取这个值。

#include <QtConcurrent>

int computeValue() {
    return 42;
}

int main() {
    QFuture<int> future = QtConcurrent::run(computeValue);
    int result = future.result();  // 获取结果
    return result;
}

注意事项

  1. 线程安全:确保你传递给 QtConcurrent::run 的函数是线程安全的,特别是当你在多个线程中访问共享数据时。
  2. 资源管理:当你在多线程环境中工作时,需要特别注意资源管理和数据同步。
  3. 生命周期管理:确保所有 QtConcurrent::run 使用的对象在任务执行期间保持有效。

2.代码1:槽函数定义——>QtConcurrent::run(Lambda表达式)——>全局函数

运行
在这里插入图片描述

#include <QApplication>
#include <QPushButton>
#include <QMainWindow>
#include <QtConcurrent>

// 假设这是一个耗时的函数
void heavyFunction() {
    // 模拟耗时操作,例如计算或数据处理
    for (int i = 0; i < 100000000; i++) {
        double x = i * 0.001;
        x = x / 2.0;
    }
}

class MainWindow : public QMainWindow {
    Q_OBJECT
public:
    MainWindow(QWidget *parent = nullptr) : QMainWindow(parent) {
        // 创建按钮
        QPushButton *pushButton = new QPushButton("Run Heavy Function", this);
        pushButton->setGeometry(100, 50, 200, 50);

        // 连接按钮的点击信号到相应的槽
        connect(pushButton, &QPushButton::clicked, this, &MainWindow::on_pushButton_clicked);
    }

public slots:
    void on_pushButton_clicked() {
        // 使用 QtConcurrent 运行重耗时函数
        QtConcurrent::run([=] {
            heavyFunction();
        });
    }
};

int main(int argc, char *argv[]) {
    QApplication app(argc, argv);

    MainWindow w;
    w.show();

    return app.exec();
}

#include "main.moc"  // 确保包含 moc 文件以处理 QObject 的元信息

3.代码2:槽函数定义——>QtConcurrent::run(Lambda表达式)——>全局函数

运行
在这里插入图片描述

#include <QApplication>
#include <QPushButton>
#include <QtConcurrent>

// 假设的耗时函数
void heavyFunction() {
    // 模拟耗时操作,例如进行复杂计算
    for (int i = 0; i < 1000000; ++i) {
        // 模拟计算
    }
}

int main(int argc, char *argv[]) {
    QApplication app(argc, argv);

    QPushButton button("Run Heavy Function");
    button.resize(200, 50);
    button.show();

    // 连接按钮的点击信号到一个 lambda 表达式,该表达式异步执行 heavyFunction
    QObject::connect(&button, &QPushButton::clicked, []() {
        QtConcurrent::run([]{
            heavyFunction();
        });
    });

    return app.exec();
}

4.代码3:槽函数定义——>QtConcurrent::run(this,&类名::成员函数)

运行
在这里插入图片描述

#include <QApplication>
#include <QMainWindow>
#include <QPushButton>
#include <QMutex>
#include <QtConcurrent>

class MainWindow : public QMainWindow {
    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr) : QMainWindow(parent) {
        // 设置主窗口的大小
        this->setFixedSize(400, 300);

        // 创建一个按钮,并设置其显示文本和父窗口
        QPushButton *button = new QPushButton("Run Heavy Function", this);
        button->setGeometry(100, 100, 200, 50);

        // 连接按钮的点击信号到相应的槽函数
        connect(button, &QPushButton::clicked, this, &MainWindow::on_pushButton_clicked);
    }

    ~MainWindow() {}

private slots:
    void on_pushButton_clicked() {
        QtConcurrent::run(this, &MainWindow::heavyFunction);
    }

private:
    void heavyFunction() {
        // 锁定互斥锁以安全访问成员变量
        mutex.lock();
        // 操作共享数据
        sharedData++;
        mutex.unlock();

        // 执行其他耗时操作
    }

    int sharedData = 0;  // 一个示例成员变量
    QMutex mutex;        // 互斥锁保护成员变量
};

#include "main.moc"

int main(int argc, char *argv[]) {
    QApplication app(argc, argv);

    MainWindow w;
    w.show();

    return app.exec();
}

5.代码4:槽函数定义——>QtConcurrent::run(Lambda表达式[this]{执行内容})

运行
在这里插入图片描述

#include <QApplication>
#include <QMainWindow>
#include <QPushButton>
#include <QMutex>
#include <QtConcurrent>

class MainWindow : public QMainWindow {
    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr) : QMainWindow(parent) {
        // 设置主窗口的大小
        this->setFixedSize(400, 300);

        // 创建一个按钮,并设置其显示文本和父窗口
        QPushButton *button = new QPushButton("Run Heavy Function", this);
        button->setGeometry(100, 100, 200, 50);

        // 连接按钮的点击信号到相应的槽函数
        connect(button, &QPushButton::clicked, this, &MainWindow::on_pushButton_clicked);
    }

    ~MainWindow() {}

private slots:
    void on_pushButton_clicked() {
        // 使用 lambda 表达式在后台线程上运行代码
        QtConcurrent::run([this] {
            // 锁定互斥锁以安全访问成员变量
            mutex.lock();
            // 操作共享数据
            sharedData++;
            mutex.unlock();

            // 执行其他耗时操作
        });
    }
private:
    int sharedData = 0;  // 一个示例成员变量
    QMutex mutex;        // 互斥锁保护成员变量
};

#include "main.moc"

int main(int argc, char *argv[]) {
    QApplication app(argc, argv);

    MainWindow w;
    w.show();

    return app.exec();
}

6.上述例程的test.pro

TEMPLATE = app
TARGET = qt_test
INCLUDEPATH += .

# Add more modules by appending them here
QT += core gui concurrent

greaterThan(QT_MAJOR_VERSION, 4): QT += widgets

SOURCES += main.cpp

HEADERS +=

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

C++进阶之路:何为拷贝构造函数,深入理解浅拷贝与深拷贝(类与对象_中篇)

✨✨ 欢迎大家来访Srlua的博文&#xff08;づ&#xffe3;3&#xffe3;&#xff09;づ╭❤&#xff5e;✨✨ &#x1f31f;&#x1f31f; 欢迎各位亲爱的读者&#xff0c;感谢你们抽出宝贵的时间来阅读我的文章。 我是Srlua小谢&#xff0c;在这里我会分享我的知识和经验。&am…

脚注:书籍的小秘密,躲藏在脚注间

脚注&#xff1a;书籍的小秘密&#xff0c;躲藏在脚注间 脚注是一种在文本中提供补充信息、引用出处或注解的方式&#xff0c;有助于读者更全面地理解文中内容&#xff0c;并为进一步研究提供参考和跳转点。 在一书本中&#xff0c;脚注是额外提供给读者的文字信息&#xff0…

SpringCloud系列(31)--使用Hystrix进行服务降级

前言&#xff1a;在上一章节中我们创建了服务消费者模块&#xff0c;而本节内容则是使用Hystrix对服务进行服务降级处理。 1、首先我们先对服务提供者的服务进行服务降级处理 (1)修改cloud-provider-hystrix-payment8001子模块的PaymentServiceImpl类 注&#xff1a;HystrixP…

Stream流的使用

目录 一&#xff0c;Stream流 1.1 概述 1.2 Stream代码示例 二&#xff0c;Stream流的使用 2.1 数据准备 2.2 创建流对象 2.3 中间操作 filter map distinct sorted limit skip flatMap 2.4 终结操作 foreach count max&min collect 2.5 查找与匹配 a…

秒级达百万高并发框架Disruptor

1、起源 Disruptor最初由lmax.com开发&#xff0c;2010年在Qcon公开发表&#xff0c;并于2011年开源&#xff0c;企业应用软件专家Martin Fowler专门撰写长文介绍&#xff0c;同年它还获得了Oracle官方的Duke大奖。其官网定义为&#xff1a;“High Performance Inter-Thread M…

2022年CSP-J入门级第一轮初赛真题

一、单项选择题&#xff08;共15题&#xff0c;每题2分&#xff0c;共计30分&#xff1b;每题有且仅有一个正确选项&#xff09; 第 1 题 在内存储器中每个存储单元都被赋予一个唯一的序号&#xff0c;称为&#xff08;&#xff09;。 A. 地址B. 序号C. 下标D. 编号 第 2 题 编…

Spring MVC+mybatis 项目入门:旅游网(三)用户注册——控制反转以及Hibernate Validator数据验证

个人博客&#xff1a;Spring MVCmybatis 项目入门:旅游网&#xff08;三&#xff09;用户注册 | iwtss blog 先看这个&#xff01; 这是18年的文章&#xff0c;回收站里恢复的&#xff0c;现阶段看基本是没有参考意义的&#xff0c;技术老旧脱离时代&#xff08;2024年辣铁铁&…

Leetcode 剑指 Offer II 079.子集

题目难度: 中等 原题链接 今天继续更新 Leetcode 的剑指 Offer&#xff08;专项突击版&#xff09;系列, 大家在公众号 算法精选 里回复 剑指offer2 就能看到该系列当前连载的所有文章了, 记得关注哦~ 题目描述 给定一个整数数组 nums &#xff0c;数组中的元素 互不相同 。返…

Introduction of Internet 计算机网络概述

计算机网络的概念 计算机网络的定义&#xff1a; 多台独立的计算机通过通信线路实现资源共享的计算机系统 计算机网络的组成 资源子网&#xff1a;提供共享的软件资源和硬件资源 通信子网&#xff1a;提供信息交换的网络结点和通信线路 计算机网络类型 按照拓扑排序 星型…

KVM+GFS分布式存储系统构建KVM高可用

KVMGFS分布式存储系统构建KVM高可用 文章目录 KVMGFS分布式存储系统构建KVM高可用资源列表基础环境一、安装部署KVM1.1、安装KVM1.2、验证1.3、开启libvirtd服务1.4、配置KVM桥接网络 二、部署GlusterFS2.1、安装GlusterFS软件2.2、所有node节点启动GFS2.3、创建GFS群集2.4、查…

[Linux]网络原理与配置

一.NAT模式网路配置 虚拟系统的IP地址处于随机网段&#xff0c;同时在母机上会额外有一个与虚拟IP地址网段相同的IP地址&#xff0c;可以实现母机与虚拟机的通信。虚拟系统的IP地址可以通过主机实际的IP地址作为代理IP&#xff0c;与外部系统进行通信。 优点&#xff1a;不造…

医疗科技:UWB模块为智能医疗设备带来的变革

随着医疗科技的不断发展和人们健康意识的提高&#xff0c;智能医疗设备的应用越来越广泛。超宽带&#xff08;UWB&#xff09;技术作为一种新兴的定位技术&#xff0c;正在引领着智能医疗设备的变革。UWB模块作为UWB技术的核心组成部分&#xff0c;在智能医疗设备中发挥着越来越…

JDBC总结

目录 JDBC(java database connection) JDBC连接数据库步骤: 1. 在项目中添加jar文件,如图所示 2.加载驱动类 向数据库中插入数据代码示例: 第一种: 第二种: 查询操作 : 第一种: 第二种: JDBC(java database connection) java数据库连接.api(应用程序编程接口) ,可…

怎么理解直接程序控制和中断方式?

直接程序控制 看完之后是不是依然一头雾水&#xff1f;来看下面两个例子 无条件传送 假设你正在使用键盘打字。当你敲击键盘上的一个键时&#xff0c;键盘会立即产生一个信号&#xff08;即输入数据&#xff09;&#xff0c;并且这个信号会立即被电脑接收。在这个过程中&…

颜色值进制转换

颜色值进制转换 专业的和非专业程序员在编程时都碰到过颜色值的表达式。特别是在编制网页和设计界面时&#xff0c;都要选择颜色。各语言的颜色值表达式就两种&#xff0c;十六进制的颜色值hex$和十进制的RGB格式。现成的调色板颜色表也是这两种格式。写代码时会遇到写颜色值码…

懒人网址导航页 search.html SQL注入漏洞复现

0x01 产品简介 懒人网址导航系统是一种智能化的网址导航平台,旨在帮助用户快速找到所需的网址和资源。该系统提供了智能化的网址搜索和推荐功能,能够根据用户的搜索习惯和偏好推荐相关的网址和资源。同时,系统还提供了网址分类、网址收藏和网址分享等功能,方便用户管理和共…

镜子摆放忌讳多

镜子是我们日常生活中不可或缺的物品。在风水中&#xff0c;镜子的作用非常多&#xff0c;能够起到一定的作用。镜子的摆放位置也是非常有讲究的&#xff0c;摆放不好会直接影响到家人的事业、财运、婚姻乃至健康等诸多方面。 第一个风水忌讳&#xff0c;镜子对大门。大门的正前…

服务器硬件全攻略:从入门到精通,全面解析服务器性能与稳定性!

服务器是计算机网络中提供特定服务的计算机系统&#xff0c;其硬件配置和性能直接影响到整个网络系统的运行效率和稳定性。作为一个资深的技术人员&#xff0c;本文将全面详细地介绍服务器硬件基础知识&#xff0c;包括介绍、命令或语法、主要作用以及使用方法等。 一、介绍 服…

CV大作业28期-使用TensorFlow快速实现图像风格迁移系统

使用TensorFlow快速实现图像风格迁移系统 资源地址&#xff1a;待更新 视频地址&#xff1a;待更新 随着GPT的横空出世&#xff0c;生成式网络也越来越活&#xff0c;现在的大语言模型除了能回答文字上面的内容&#xff0c;并且在图像和视频创作中也表现除了巨大的潜力&#xf…