Studying-多线程学习Part4 - 异步并发——async future、packaged_task、promise

news/2024/12/22 10:26:01/

异步并发——async future packaged_task promise

1.async、future

是C++11引入的一个函数模版,用于异步执行一个函数,并返回一个future对象,表示异步操作的结果。使用 async 可以方便地进行异步编程,避免了手动创建线程和管理线程的麻烦。 

代码参考:

#include<iostream>
#include<future>
#include<thread>
using namespace std;int func() {int i = 0;for (int j = 0; j < 1000; ++j) {i++;}return i;
}int main() {future<int> future_result = async(launch::async, func);cout << func() << endl;cout << future_result.get() << endl;return 0;
}

这个例子中,使用了async函数异步执行了一个耗时的计算,这个计算可以在另一个线程中执行,不会阻塞主线程。同时,我们也避免了手动创建线程和管理线程的麻烦。

2.packaged_task 

在C++中,packaged_task是一个类模板,用于将一个可调用对象(如函数、函数对象或Lambda表达式)封装成一个异步撮作,并返回一个std::future对象,表示异步操作的结果。packaged_task可以方便地将一个函数或可调用对象转换成一个异步操作,供其他线程使用。

代码参考:

#include<iostream>
#include<future>
#include<thread>
using namespace std;int func() {int i = 0;for (int j = 0; j < 1000; ++j) {i++;}return i;
}int main() {packaged_task<int()> task(func);future<int>future_result = task.get_future();thread t1(move(task));cout << func() << endl;t1.join();cout << future_result.get() << endl;return 0;
}

在这个例子中,我们成功地将一个函数封装成了一个异步操作,并在其他线程中执行。通过packaged_task和future对象,我们可以方便地实现异步编程,使得代码更加简洁和易于维护。 

3.promise

在C++中,promise是一个类模版,用于在一个线程中产生一个值,并在另一个线程中获取这个值。promise通常与future和async一起使用,用于实现异步编程。

#include<iostream>
#include<future>
using namespace std;void fun(promise<int>& f) {f.set_value(1000); //传入数据
}int main() {promise<int> f;auto future_result = f.get_future();thread t1(fun, ref(f));t1.join();cout << future_result.get() << endl;return 0;}

实现一个数据的传入和使用。 


原子操作 atomic

`std::atomic` 是 C++11 标准库中的一个模板类,用于实现多线程环境下的原子操作。它提供了一种线程安全的方式来访问和修改共享变量,可以避免多线程环境中的数据竞争问题。

`std::atomic` 的使用方式类似于普通的 C++ 变量,但是它的操作是原子性的。也就是说,在多线程环境下,多个线程同时对同一个 `std::atomic` 变量进行操作时,不会出现数据竞争问题。

以下是一些常用的 `std::atomic` 操作:

  1. `load()`:将 `std::atomic` 变量的值加载到当前线程的本地缓存中,并返回这个值。
  2. `store(val)`:将 `val` 的值存储到 `std::atomic` 变量中,并保证这个操作是原子性的。
  3. `exchange(val)`:将 `val` 的值存储到 `std::atomic` 变量中,并返回原先的值。
  4. `compare_exchange_weak(expected, val)` 和 `compare_exchange_strong(expected, val)`:比较 `std::atomic` 变量的值和 `expected` 的值是否相同,如果相同,则将 `val` 的值存储到 `std::atomic` 变量中,并返回 `true`;否则,将 `std::atomic` 变量的值存储到 `expected` 中,并返回 `false`。

代码参考:

#include<iostream>
#include<thread>
#include<atomic>
using namespace std;//原子量
atomic<int> sharted_data = 0;
void func() {for (int i = 0; i < 10000; ++i) {sharted_data++; //对原子量数据操作是线程安全的 }
}
int main() {thread t1(func);thread t2(func);t1.join();t2.join();cout << sharted_data << endl;return 0;
}

http://www.ppmy.cn/news/1535889.html

相关文章

【Kubernetes】常见面试题汇总(五十四)

目录 120.创建 init C 容器后&#xff0c;其状态不正常&#xff1f; 特别说明&#xff1a; 题目 1-68 属于【Kubernetes】的常规概念题&#xff0c;即 “ 汇总&#xff08;一&#xff09;~&#xff08;二十二&#xff09;” 。 题目 69-113 属于【Kubernetes】的生产…

《机器学习》周志华-CH10(降维与度量学习)

10.1k近邻学习 k k k近邻(k-Nearest Neighbor,简称kNN)&#xff0c;监督学习。 工作机制&#xff1a;给定测试样本&#xff0c;基于某种距离度量找出训练集中与其最靠近的 k k k个训练样本&#xff0c;基于这些”邻居“预测。 { 分类任务&#xff1a;选择”投票法“。 k 个样本…

解决Python使用Selenium 时遇到网页 <body> 划不动的问题

如果在使用 Selenium 时遇到网页的 <body> 划不动的问题&#xff0c;这通常是因为页面的滚动机制&#xff08;例如&#xff0c;可能使用了一个具有固定高度的容器或自定义的滚动条&#xff09;导致无法通过简单的 JavaScript 实现滚动。可以通过以下方法来解决该问题。 …

STM32(五)GPIO输入硬件电路及C语言知识复习

本小节主要是GPIO输入模式下的硬件电路和C语言知识的回顾 C语言中的数据&#xff1a;定义和引用 一、GPIO输入模式下的硬件和电路 1.按键介绍 可以用延时函数消除按键抖动 2.传感器模块介绍 &#xff08;1&#xff09;传感器元件的电阻会随模拟量的变化而变化&#xff0c;通…

【2024年最新】基于springboot+mysql就业信息管理系统

技术摘要 技术框架&#xff1a;以springboot作为框架&#xff0c;业务模式&#xff1a;B/S模式数据库&#xff1a;MySql作为后台运行的数据库服务器&#xff1a;使用Tomcat用为系统的服务器 系统展示 系统实现功能 本次实现一个就业信息管理系统&#xff0c;通过这个系统能够满…

k8s 之安装busybox

作者&#xff1a;程序那点事儿 日期&#xff1a;2024/02/12 14:56 busybox是linux的一个工具镜像&#xff0c;包含我们常用的一些工具。可以利用这个工具来做一些测试的操作。 安装命令 # 运行一个容器。 kubectl run -it --image busybox:1.28.4 dns-test --restartN…

上海我店:创新模式引领本地生活新风尚

近年来&#xff0c;一个名为“上海我店”的新兴平台在网络空间中迅速崛起&#xff0c;其公布的业绩令人瞩目——在短短三年内&#xff0c;交易流水已跨越百亿大关&#xff0c;并在最近一个月内迎来了近百万的新增注册用户。这一强劲的增长势头&#xff0c;无疑吸引了众多商家和…

EtherNet/IP 转 EtherNet/IP, EtherCAT/Ethernet/IP/Profinet/ModbusTCP协议互转工业串口网关

EtherCAT/Ethernet/IP/Profinet/ModbusTCP协议互转工业串口网关https://item.taobao.com/item.htm?ftt&id822721028899 协议转换通信网关 EtherNet/IP 转 EtherNet/IP GW系列型号 MS-GW22 概述 简介 MS-GW22 是 EtherNet/IP 和 EtherNet/IP 协议转换网关&#xff0c;…