C++ 异步编程是 并发编程技术

news2024/10/5 14:12:41

C++ 异步编程是一种并发编程技术,用于通过非阻塞的方式执行任务。与传统的同步编程相比,异步编程可以提高程序的效率,尤其是在处理 I/O 操作、网络请求或多线程任务时,避免主线程等待任务完成。

1. 异步编程的基本概念

异步编程主要解决如何在不阻塞主线程的情况下,执行耗时的任务,并在任务完成时以某种方式通知或继续执行程序的其他部分。在 C++ 中,异步编程的主要机制包括:

多线程(Threading):通过多线程来实现并行执行任务。
异步任务(Asynchronous Task):通过 std::future 和 std::promise 等方式执行异步任务。
事件循环和回调(Event Loop & Callbacks):通过事件触发器在任务完成后执行相应的回调函数。
异步编程的主要目标是:

提高程序的响应性,尤其是 UI 程序或网络服务。
更好地利用系统资源,避免线程或 CPU 被阻塞在等待上。

2. C++ 中的异步编程工具

C++11 引入了大量支持异步编程的库和工具,使得 C++ 异步编程变得更加易用和标准化。以下是 C++ 异步编程的几种主要方式:

2.1. std::thread

std::thread 是 C++ 中用来创建和管理线程的基本工具。线程使得多个任务能够并发运行。

  • 创建线程:
#include <iostream>
#include <thread>

void task(int n) {
    std::cout << "Task " << n << " is running in a separate thread.\n";
}

int main() {
    std::thread t(task, 10);
    t.join();  // 等待线程 t 执行完成
    return 0;
}
  • 线程的生命周期:
join():等待线程执行完毕,阻塞主线程直到子线程结束。
detach():让线程在后台运行,主线程不等待其完成。
使用 std::thread 虽然可以实现简单的并发任务,但对于复杂的异步任务管理,需要更高层次的抽象,如 std::async。

2.2. std::async 和 std::future

std::async 是 C++11 提供的更高层的异步编程接口。它可以创建一个异步任务,并返回一个 std::future 对象来获取异步任务的结果。

  • 异步任务的执行:
#include <iostream>
#include <future>
#include <thread>

int long_computation(int n) {
    std::this_thread::sleep_for(std::chrono::seconds(2));  // 模拟长时间计算
    return n * n;
}

int main() {
    // 创建一个异步任务
    std::future<int> result = std::async(std::launch::async, long_computation, 10);

    // 执行其他任务
    std::cout << "Doing other things while waiting...\n";

    // 获取异步任务的结果
    int value = result.get();  // 这个操作会阻塞主线程直到结果准备好
    std::cout << "Result is " << value << "\n";
    return 0;
}
  • std::async 的模式:

std::launch::async:强制在新线程中异步执行。
std::launch::deferred:任务不会立即执行,只有调用 get() 或 wait() 时才会执行。
std::future 是 std::async 的返回类型,用于表示一个异步操作的结果。它提供以下几个重要的方法:

get():阻塞主线程直到任务完成并返回结果。
wait():阻塞主线程,直到任务完成,但不返回结果。
wait_for() 和 wait_until():允许设置等待超时,检查任务是否完成。

2.3. std::promise 和 std::future

std::promise 和 std::future 是 C++ 提供的另一组异步任务管理工具。std::promise 用于设置异步操作的结果,而 std::future 用于获取结果。

  • std::promise 和 std::future 的用法:
#include <iostream>
#include <thread>
#include <future>

void calculate_square(std::promise<int>&& p, int n) {
    int result = n * n;
    std::this_thread::sleep_for(std::chrono::seconds(2));
    p.set_value(result);  // 设置结果
}

int main() {
    std::promise<int> p;  // 创建 promise 对象
    std::future<int> result = p.get_future();  // 获取 future

    // 启动线程并将 promise 对象传递进去
    std::thread t(calculate_square, std::move(p), 10);

    // 主线程做其他事情
    std::cout << "Waiting for result...\n";
    
    // 获取结果(会阻塞主线程)
    int value = result.get();
    std::cout << "Result is " << value << "\n";

    t.join();
    return 0;
}

这种方式适用于更加复杂的异步任务场景,特别是当你需要手动控制任务的开始和结束时。

2.4. std::packaged_task

std::packaged_task 是 C++11 提供的一种将任务打包为可异步调用的工具。它可以与 std::future 一起使用,允许我们将函数、lambda 表达式等包装为异步任务。

  • std::packaged_task 示例:
#include <iostream>
#include <future>
#include <thread>

int compute_sum(int a, int b) {
    return a + b;
}

int main() {
    std::packaged_task<int(int, int)> task(compute_sum);  // 打包任务
    std::future<int> result = task.get_future();  // 获取 future 对象

    std::thread t(std::move(task), 5, 7);  // 启动线程,传入参数

    std::cout << "Result: " << result.get() << "\n";  // 获取结果

    t.join();
    return 0;
}

2.5. std::mutex、std::lock_guard 和 std::unique_lock

在异步编程或多线程编程中,保护共享资源免受并发访问是至关重要的。C++ 提供了 std::mutex(互斥量)来保护共享数据。std::lock_guard 和 std::unique_lock 提供了自动锁定和解锁的机制,避免手动管理锁的复杂性。

  • 使用 std::mutex 进行线程同步:
#include <iostream>
#include <thread>
#include <mutex>

std::mutex mtx;  // 互斥量保护共享资源

void print_message(const std::string& message) {
    std::lock_guard<std::mutex> lock(mtx);  // 自动加锁和解锁
    std::cout << message << std::endl;
}

int main() {
    std::thread t1(print_message, "Hello from thread 1");
    std::thread t2(print_message, "Hello from thread 2");

    t1.join();
    t2.join();
    return 0;
}

std::unique_lock 的灵活性: std::unique_lock 比 std::lock_guard 更加灵活,支持延迟加锁、手动解锁等操作。

std::unique_lock<std::mutex> lock(mtx);
lock.unlock();  // 手动解锁
lock.lock();    // 手动加锁

3. C++ 异步编程的实际应用场景

C++ 的异步编程在以下几种场景中有着广泛的应用:

3.1. 高性能 I/O

异步 I/O 操作避免了主线程的阻塞,特别是在高并发的网络服务中,通过异步操作处理大量的请求可以显著提高吞吐量。

3.2. 并行计算

对于计算密集型任务,使用多线程或异步任务将计算拆分为多个并发执行的任务,能够更有效地利用多核 CPU 提升性能。

3.3. 事件驱动编程

在 GUI 或服务器编程中,异步编程能够避免用户界面或服务器的主线程被阻塞,从而保持系统的响应性。

4. 总结

C++ 提供了多种异步编程工具,从基本的 std::thread 到更高级的 std::async 和 std::future。异步编程可以显著提高程序的效率,特别是在 I/O 密集型和计算密集型任务中。熟悉这些工具的使用,能够帮助开发者编写出更高效、响应更快的程序。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

无神论文解读之ControlNet:Adding Conditional Control to Text-to-Image Diffusion Models

一、什么是ControlNet ControlNet是一种能够控制模型生成内容的方法&#xff0c;能够对文生图等模型添加限制信息&#xff08;边缘、深度图、法向量图、姿势点图等&#xff09;&#xff0c;在当今生成比较火的时代很流行。 这种方法使得能够直接提供空间信息控制图片以更细粒…

招联2025校招内推倒计时

【投递方式】 直接扫下方二维码&#xff0c;或点击内推官网https://wecruit.hotjob.cn/SU61025e262f9d247b98e0a2c2/mc/position/campus&#xff0c;使用内推码 igcefb 投递&#xff09; 【招聘岗位】 后台开发 前端开发 数据开发 数据运营 算法开发 技术运维 软件测试 产品策…

【课程学习】随机过程之泊松过程

随机过程之泊松过程 泊松分布泊松过程 泊松分布 二项分布是离散性的分布&#xff0c;泊松分布是把二项分布取n趋于无穷得到的连续分布。也就是在一段时间内不停的观察某件事情发生的次数。 如&#xff1a;一个小时内观察一段路上经过行人的数目&#xff0c;如果每个半个小时观…

nginx和gateway的关系和区别

在技术选型时&#xff0c;选择 Nginx 和 Spring Cloud Gateway&#xff08;或简称为 Gateway&#xff09;主要取决于具体应用场景和技术需求。下面是两者的一些关键差异和适用场景。 一、Nginx 概念 Nginx 是一个高性能的 Web 服务器和反向代理服务器&#xff0c;常被用作静…

智能手表(Smart Watch)项目

文章目录 前言一、智能手表&#xff08;Smart Watch&#xff09;简介二、系统组成三、软件框架四、IAP_F411 App4.1 MDK工程结构4.2 设计思路 五、Smart Watch App5.1 MDK工程结构5.2 片上外设5.3 板载驱动BSP5.4 硬件访问机制-HWDataAccess5.4.1 LVGL仿真和MDK工程的互相移植5…

CSRF | CSRF 漏洞介绍

关注这个漏洞的其他相关笔记&#xff1a;CSRF 漏洞 - 学习手册-CSDN博客 0x01&#xff1a;CSRF 漏洞简介 CSRF&#xff08;Cross-Site request forgery&#xff0c;跨站请求伪造&#xff09;也被称为 One Click Attack 或者 Session Riding&#xff0c;通常缩写为 CSRF 或者 X…

【Java】IntelliJ IDEA开发环境安装

一、下载 官方地址&#xff1a;https://www.jetbrains.com/idea/ 点击Download直接下载 二、安装 双击安装包&#xff0c;点击Next 选择安装路径&#xff0c;点击Next 勾选安装内容 安装完成。 三、创建项目 打开IDEA&#xff0c;填写项目名称&#xff0c;选择项目安装路径…

S7-200 SMART的数据类型说明

S7-200 SMART的数据主要分为&#xff1a; 与实际输入/输出信号相关的输入/输出映象区&#xff1a; I&#xff1a;数字量输入&#xff08;DI&#xff09;Q&#xff1a;数字量输出&#xff08;DO&#xff09;AI&#xff1a;模拟量输入AQ&#xff1a;模拟量输出 内部数据存储区…

STM32 Hal库SDIO在FATFS使用下的函数调用关系

STM32 Hal库SDIO在FATFS使用下的函数调用关系 本文并不将FATFS的相关接口操作&#xff0c;而是将HAL在使用FATFS通过SDIO外设管理SD卡时&#xff0c;内部函数的调用逻辑&#xff0c;有助于当我们使用CUBEMX生成FATFS读取SD卡的代码时无法运行时Debug。本文也会说明一些可能出现…

如何编写一个优雅的commit message

在Git中&#xff0c;git commit 命令扮演着至关重要的角色。它的主要作用是将暂存区&#xff08;staging area&#xff09;里的改动内容提交到本地仓库&#xff08;repository&#xff09;中&#xff0c;形成一个新的版本或提交&#xff08;commit&#xff09;。这个过程是 Git…

渗透测试入门学习——使用python脚本自动识别图片验证码,OCR技术初体验

写在前面 由于验证码在服务端生成后存储在服务器的session中&#xff0c;而标用于标识用户身份的sessionid存在于用户cookie中 所以本次识别验证码时需要用requests.session()创建会话对象&#xff0c;模拟真实的浏览器行为&#xff0c;保持与服务器的会话才能获取登录时服务…

wsl2 ubuntu 桥接以太网卡

注意&#xff1a;此方法需要至少 Windows 11 22H2。桥接模式就是将主机网卡与虚拟机虚拟的网卡利用虚拟网桥进行通信。 在桥接的作用下&#xff0c;类似于把宿主机虚拟为一个交换机&#xff0c;所有桥接设置的虚拟机连接到这个交换机的一个接口上&#xff0c;宿主机也同样插在这…

通信工程学习:什么是RARP反向地址解析协议

RARP&#xff1a;反向地址解析协议 RARP&#xff08;Reverse Address Resolution Protocol&#xff0c;反向地址解析协议&#xff09;是一种网络协议&#xff0c;其主要作用是在设备只知道物理地址&#xff08;如MAC地址&#xff09;时&#xff0c;允许其从网关服务器的地址解析…

致亲爱的Android studio

你的未来发展趋势&#xff1a; 可不可以把兼容性&#xff0c;什么的搞得更好。起因是我想写期末大作业&#xff0c;然后简单的把功能写的差不多了之后&#xff0c;我就想到处看看有没有一套比较好的类似于组件库的东西&#xff0c;但是没找到&#xff0c;然后就把目标锁定到了G…

Vue入门-Node.js安装

进入Node.js中文网 ​​​​​​​点击进入Node.js中文网 或者手动输入网址&#xff1a; https://www.nodejs.com.cn/download.html 点击下载64位安装包&#xff1a; 下载好之后双击进行安装 可选择个性化安装或默认安装 直接点【Next】按钮&#xff0c;此处可根据个人需求…

深度解析 HTTP

我的主页&#xff1a;2的n次方_ 1. HTTP 的简单介绍 HTTP &#xff1a;超文本传输协议&#xff0c;不仅能传输文本&#xff0c;还能传输图片&#xff0c;音频文件&#xff0c;视频 目前基本上都用的是 1.1 版本 https 可以认为是 http 的升级版&#xff0c;区别就是引入了…

【pytorch】张量求导4

再再接上文&#xff0c;看到作者有一个关于向量乘矩阵的描述。 经过搜索发现&#xff0c;现在的pytorch已经修复了这一问题&#xff0c;提供了mv()和matmul()两种方式实现矩阵和一维向量的乘积&#xff0c;可以参看这篇文章。 经过查阅pytorch的文件&#xff0c;找到了cuda侧…

如何利用 Kubernetes 取得成功

Kubernetes是一个开源编排平台&#xff0c;用于自动部署和管理容器化工作负载和服务&#xff0c;目前越来越受欢迎。 该平台由全球贡献者社区维护&#xff0c;其潜在优势包括提高资源效率、提高可扩展性和高可用性。 在过去几年中&#xff0c;Kubernetes 和相关的云原生技术已…

[Qt] 基于 Qt 的文件选择与图片显示功能实现

文章目录 基础版本&#xff1a;open1()功能解析&#xff1a;特点与限制&#xff1a; 增加路径记忆功能&#xff1a;open2()功能解析&#xff1a;特点与改进&#xff1a; 使用智能指针优化内存管理&#xff1a;open3()功能解析&#xff1a;特点与改进&#xff1a; 图片自适应窗口…

线程互斥函数的例子

代码 #include<stdio.h> #include<pthread.h> #include<sched.h> void *producter_f(void *arg); void *consumer_f(void *arg); int buffer_has_item0; pthread_mutex_t mutex; int running1; int main(void) {pthread_t consumer_t;pthread_t producter_t…