C++11并发与多线程笔记（9） async、future、packaged_task、promise

C++11并发与多线程笔记（9） async、future、packaged_task、promise

  • 1、std::async、std::future创建后台任务并返回值
  • 2、std::packaged_task：打包任务，把任务包装起来
  • 3、std::promise
  • 3、小结

1、std::async、std::future创建后台任务并返回值

std::async： 是一个函数模板，用来启动一个异步任务，启动起来一个异步任务之后，它返回一个std::future对象，这个对象是个类模板。

什么叫“启动一个异步任务”？就是自动创建一个线程，并开始执行对应的线程入口函数，它返回一个std::future对象，这个std::future对象中就含有线程入口函数所返回的结果，我们可以通过调用future对象的成员函数get()来获取结果。

“future”将来的意思，也有人称呼std::future提供了一种访问异步操作结果的机制，就是说这个结果你可能没办法马上拿到，但是在不久的将来，这个线程执行完毕的时候，你就能够拿到结果了，所以，大家这么理解：future中保存着一个值，这个值是在将来的某个时刻能够拿到。

std::future对象的get()成员函数会等待线程执行结束并返回结果，拿不到结果它就会一直等待，感觉有点像join()。但是，它是可以获取结果的。

std::future对象的wait()成员函数，用于等待线程返回，本身并不返回结果，这个效果和 std::thread 的join()更像。

#include <iostream>
#include <future>
using namespace std;
class A {
public:
	int mythread(int mypar) {
		cout << mypar << endl;
		cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
		std::chrono::milliseconds dura(5000);//定义一个5秒的时间
	    std::this_thread::sleep_for(dura);//创建一个线程并开始执行，绑定关系
	    cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;//卡在这里等待mythread()执行完毕，拿到结果
		return mypar;
	}
};
 
int mythread() {
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
	std::chrono::milliseconds dura(5000);//定义一个5秒的时间
	std::this_thread::sleep_for(dura);//创建一个线程并开始执行，绑定关系
	cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;//卡在这里等待mythread()执行完毕，拿到结果
	return 5;
}
 
 
int main() {
	A a;
	int tmep = 12;
	cout << "main" << "threadid = " << std::this_thread::get_id() << endl;
	std::future<int> result1 = std::async(mythread);
	cout << "continue........" << endl;
	cout << result1.get() << endl; //卡在这里等待mythread()执行完毕，拿到结果，只能使用一次
	
	//类成员函数
	std::future<int> result2 = std::async(&A::mythread, &a, temp); //第二个参数是对象引用才能保证线程里执行的是同一个对象
	cout << result2.get() << endl;
   //或者result2.wait(); //等待线程返回，本身不返回结果
	cout << "good luck" << endl;
	return 0;
}

我们通过向std::async()传递一个参数，该参数是std::launch类型（枚举类型），来达到一些特殊的目的：

  1. std::lunch::deferred：
    （defer推迟，延期）表示线程入口函数的调用会被延迟，一直到std::future的wait()或者get()函数被调用时（由主线程调用）才会执行；如果wait()或者get()没有被调用，则不会执行。
    重点：实际上根本就没有创建新线程。std::launch::deferred意思时延迟调用，并没有创建新线程，是在主线程中调用的线程入口函数。
#include <iostream>
#include <future>
using namespace std;
class A {
public:
	int mythread(int mypar) {
		cout << mypar << endl;
		cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
		std::chrono::milliseconds dura(5000);
		std::this_thread::sleep_for(dura);
		cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
		return mypar;
	}
};

int main() {
	A a;
	int temp = 12;
	cout << "main" << "threadid = " << std::this_thread::get_id() << endl;
	cout << "continue........" << endl;
	std::future<int> result1 = std::async(std::launch::deferred, &A::mythread, &a, temp);
	cout << result1.get() << endl;
	//或者result2.wait();
	cout << "I love China！" << endl;
	return 0;
}

在这里插入图片描述

  1. std::launch::async，在调用async函数的时候就开始创建新线程，不添加标记，默认用的就是默认值是 std::launch::async | std::launch::deferred 标记。
int main() {
	A a;
	int temp = 12;
	cout << "main" << "threadid = " << std::this_thread::get_id() << endl;
	cout << "continue........" << endl;
	std::future<int> result1 = std::async(std::launch::async, &A::mythread, &a, temp);//使用std::launch::async标记
	cout << result1.get() << endl;
	//或者result2.wait();
	cout << "I love China！" << endl;
	return 0;
}
  1. 同时使用std::launch::async和std::lunch::deferred标记，并不能在新线程中延迟调用。

2、std::packaged_task：打包任务，把任务包装起来

类模板，它的模板参数是各种可调用对象，通过packaged_task把各种可调用对象包装起来，方便将来作为线程入口函数来调用。

#include <thread>
#include <iostream>
#include <future>
using namespace std;
 
int mythread(int mypar) {
	cout << mypar << endl;
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
	std::chrono::milliseconds dura(5000);
	std::this_thread::sleep_for(dura);
	cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
	return 5;
}
 
int main() {
	cout << "main" << "threadid = " << std::this_thread::get_id() << endl;
	//我们把函数mythread通过packaged_task包装起来
    //参数是一个int，返回值类型是int
    //方法1
    std::packaged_task<int(int)> mypt(mythread);
	std::thread t1(std::ref(mypt), 1);//线程开始执行
	t1.join();//等待线程执行完毕
	std::future<int> result = mypt.get_future(); 
	//std::future对象里包含有线程入口函数的返回结果，这里result保存mythread返回的结果。
	cout << result.get() << endl;
	return 0;
}

可调用对象可由函数换成lambda表达式

int main() {
    //方法2,用lambda表达式
    std::packaged_task<int(int)> mypt([](int mypar）{
   	cout << mypar << endl;
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
    std::chrono::milliseconds dura(5000);
    std::this_thread::sleep_for(dura);
    cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
	return 5;
    });
    std::thread t1(std::ref(mypt), 1);
	t1.join();
	std::future<int> result = mypt.get_future(); 
	//std::future对象里包含有线程入口函数的返回结果，这里result保存mythread返回的结果。
	cout << result.get() << endl;
	cout << "I love China！" << endl;
	return 0;
}

packaged_task包装起来的可调用对象还可以直接调用，从这个角度来讲，packaged_task对象也是一个可调用对象
lambda的直接调用

int main() {
    //方法2,用lambda表达式
    std::packaged_task<int(int)> mypt([](int mypar）{
   	cout << mypar << endl;
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
    std::chrono::milliseconds dura(5000);
    std::this_thread::sleep_for(dura);
    cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
	return 5;
    });
    //packaged_task包装起来的可调用对象还可以直接调用，所以从这个角度来讲，pakcaged_task对象，也是一个可调用对象;
    mypt(105);//直接调用，相当于函数调用
    std::future<int> result=mypt.get_future();
    cout<<result.get()<<endl; 
	return 0;
}

包装后存放容器里

vector<std::packaged<int(int)>> mytasks;
int main() {
    //方法2,用lambda表达式
    std::packaged_task<int(int)> mypt([](int mypar）{
   	cout << mypar << endl;
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
    std::chrono::milliseconds dura(5000);
    std::this_thread::sleep_for(dura);
    cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
	return 5;
    });
	mytasks.push_back(std::move(mypt));//入容器，进去用了移动语义，入进去之后mypt就为空
	std::packaged_task<int(int)>mypt2;
	auto iter=mytask.begin();
	mypt2=std::move(*iter);//移动语义
	mytasks.erase(iter);//删除第一个元素，迭代已经失效了，所以后续代码不可以再使用iter
    mypt2(105);//直接调用，相当于函数调用
    std::future<int> result=mypt2.get_future();
    cout<<result.get()<<endl; 
	return 0;
}

3、std::promise

类模板，我们能够在某个线程中给它赋值，然后我们可以在其他线程中，把这个值取出来

#include <thread>
#include <iostream>
#include <future>
using namespace std;
 
void mythread(std::promise<int> &tmpp, int clac) {
	//做一系列复杂的操作
	clac++;
	clac *=10;
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
	std::chrono::milliseconds dura(5000);
	std::this_thread::sleep_for(dura);
	cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
	int result = clac;//保存结果
	tmp.set_value(result); //结果保存到了tmp这个对象中
	return;
}
 
int main() {
	std::promise<int> myprom;
	std::thread t1(mythread, std::ref(myprom), 180);
	t1.join(); //在这里线程已经执行完了
	std::future<int> fu1 = myprom.get_future(); //promise和future绑定，用于获取线程返回值
	auto result = fu1.get();//get只能调用1次
	cout << "result = " << result << endl;
	cout<<"I love China!"<<endl;
}

总结：通过promise保存一个值，在将来某个时刻我们通过把一个future绑定到这个promise上，来得到绑定的值

使用两个子进程

#include <thread>
#include <iostream>
#include <future>
using namespace std;
 
void mythread(std::promise<int> &tmpp, int clac) {
	//做一系列复杂的操作
	clac++;
	clac *=10;
	cout << "mythread() start" << "threadid = " << std::this_thread::get_id() << endl;
	std::chrono::milliseconds dura(5000);
	std::this_thread::sleep_for(dura);
	cout << "mythread() end" << "threadid = " << std::this_thread::get_id() << endl;
	int result = clac;//保存结果
	tmp.set_value(result); //结果保存到了tmp这个对象中
	return;
}
 
void mythread2(std::future<int> &tmpf){
	auto result=tmpf.get();
	cout<<"mythread2.result"<<result<<endl;
	return;
}
 
int main() {
	std::promise<int> myprom;
	std::thread t1(mythread, std::ref(myprom), 180);
	t1.join(); //在这里线程已经执行完了
	std::future<int> fu1 = myprom.get_future(); //promise和future绑定，用于获取线程返回值
	
	std::thread t2(mythread2,std::ref(ful));
	t2.join();//等mythread2线程执行完毕
	
	cout<<"I love China!"<<endl;
}

总结：第一个线程1(t1) 计算了一个结果，结果通过future对象给到第二个线程2(t2)。

注意：使用thread时，必须 join() 或者 detach() 否则程序会报异常

3、小结

我们学习这些东西的目的并不是，要把他们都用到实际开发中。
相反，如果我们能够用最少的东西写出一个稳定的，高效的多线程程序，更值得赞赏。
我们为了成长必须阅读一些高手写的代码，从而实现自己代码的积累；

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

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

相关文章

编程练习（3）

编程练习（3）

一.选择题 第一题&#xff1a; 函数传参的两个变量都是传的地址&#xff0c;而数组名c本身就是地址&#xff0c;int型变量b需要使用&符号&#xff0c;因此答案为A 第二题&#xff1a; 本题考察const修饰指针变量&#xff0c;答案为A,B,C,D 第三题&#xff1a; 注意int 型变…
阅读更多...
Linux忘记root密码解决方法

Linux忘记root密码解决方法

当我们忘记root密码进不去服务器怎么办&#xff1f;不要担心&#xff0c;可以进入到linux的救援模式修改root密码。 下面直接上干货&#xff0c;流程如下&#xff1a; 1.重启电脑&#xff0c;按上下键滑动&#xff0c;保证不进入开机流程&#xff0c;然后按e键 2.出现此页面…
阅读更多...
Mac 开发 Tang Nano FPGA 指南（使用终端和使用 VS Code 和插件，适用所有 Gowin FPGA）

Mac 开发 Tang Nano FPGA 指南（使用终端和使用 VS Code 和插件，适用所有 Gowin FPGA）

最近收到了一个 Tang nano 9K FPGA开发板&#xff0c;就想借此机会研究一下。 官方文档里介绍如果想使用高云的 FPGA&#xff0c;就需要使用 GOWIN IDE&#xff0c;但是需要申请 license 提交一堆资料&#xff0c;我是别人送的就不太方便让别人弄。加上 IDE 其实并不是很适合学…
阅读更多...
2023-08-19 LeetCode每日一题（两整数相加）

2023-08-19 LeetCode每日一题（两整数相加）

2023-08-19每日一题 一、题目编号 2235. 两整数相加二、题目链接 点击跳转到题目位置 三、题目描述 给你两个整数 num1 和 num2&#xff0c;返回这两个整数的和。 示例 1&#xff1a; 示例 2&#xff1a; 提示&#xff1a; -100 < num1, num2 < 100 四、解题代…
阅读更多...
idea2023 springboot2.7.5+mybatisplus3.5.2+jsp 初学单表增删改查

idea2023 springboot2.7.5+mybatisplus3.5.2+jsp 初学单表增删改查

创建项目 修改pom.xml 为2.7.5 引入mybatisplus 2.1 修改pom.xml <dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.2</version></dependency><!--mysq…
阅读更多...
Vue elementui 实现表格selection的默认勾选,翻页记录勾选状态

Vue elementui 实现表格selection的默认勾选,翻页记录勾选状态

需求&#xff1a;当弹出一个列表页数据&#xff0c;对其进行筛选选择。 列表更新&#xff0c;填充已选数据 主要使用toggleRowSelection 代码如下&#xff1a; <el-table v-loading"loading" :data"drugList" selection-change"handleSelection…
阅读更多...
华为手机Outlook手机APP无法登录邮箱，提示[2002]错误代码

华为手机Outlook手机APP无法登录邮箱，提示[2002]错误代码

近期遇到不少华为手机的Outlook APP无法登录邮箱Office365邮箱的案例&#xff0c;并且提示&#xff1a; 错误 出错了。[2002] 经测试&#xff0c;这应该是华为应用市场下载的Outlook版本有问题。 解决方法&#xff1a; 把Outlook卸载之后从微软官网重新下载官网版本去安装&am…
阅读更多...
通过 kk 创建 k8s 集群和 kubesphere

通过 kk 创建 k8s 集群和 kubesphere

官方文档&#xff1a;多节点安装 确保从正确的区域下载 KubeKey export KKZONEcn下载 KubeKey curl -sfL https://get-kk.kubesphere.io | VERSIONv3.0.7 sh -为 kk 添加可执行权限&#xff1a; chmod x kk创建 config 文件 KubeSphere 版本&#xff1a;v3.3 支持的 Kuber…
阅读更多...
2018年3月全国计算机等级考试真题（语言二级C）

2018年3月全国计算机等级考试真题（语言二级C）

2018年3月全国计算机等级考试真题&#xff08;语言二级C&#xff09; 第1题 设有定义&#xff1a;char s[81]&#xff1b;int i0&#xff1b;以下不能将一行带有空格的字符串正确读入的语句或语句组是 A. while((s[i]getchar())!\n);s[i]\0; B. scanf("%s",s); C.…
阅读更多...
Centos7完全卸载已安装的Nginx

Centos7完全卸载已安装的Nginx

docker实战(一):centos7 yum安装docker docker实战(二):基础命令篇 docker实战(三):docker网络模式(超详细) docker实战(四):docker架构原理 docker实战(五):docker镜像及仓库配置 docker实战(六):docker 网络及数据卷设置 docker实战(七):docker 性质及版本选择 认知升…
阅读更多...
Unsafe Filedownload

Unsafe Filedownload

文件下载功能在很多web系统上都会出现&#xff0c;一般我们当点击下载链接&#xff0c;便会向后台发送一个下载请求&#xff0c;一般这个请求会包含一个需要下载的文件名称&#xff0c;后台在收到请求后会开始执行下载代码&#xff0c;将该文件名对应的文件response给浏览器&am…
阅读更多...
Python土力学与基础工程计算.PDF-螺旋板载荷试验

Python土力学与基础工程计算.PDF-螺旋板载荷试验

python 求解代码如下&#xff1a; 1. import numpy as np 2. 3. # 已知参数 4. p_a 100 # 标准压力&#xff0c; kPa 5. p np.array([25, 50, 100, 200) # 荷载&#xff0c; kPa 6. s np.array([2.88, 5.28, 9.50, 15.00) / 10 # 沉降量&#xff0c; cm 7. D 10 # 螺旋板直…
阅读更多...
云安全攻防（十二）之 手动搭建 K8S 环境搭建

云安全攻防（十二）之 手动搭建 K8S 环境搭建

手动搭建 K8S 环境搭建 首先前期我们准备好三台 Centos7 机器&#xff0c;配置如下&#xff1a; 主机名IP系统版本k8s-master192.168.41.141Centos7k8s-node1192.168.41.142Centos7k8s-node2192.168.41.143Centos7 前期准备 首先在三台机器上都执行如下的命令 # 关闭防火墙…
阅读更多...
Linux学习之基本指令二

Linux学习之基本指令二

-----紧接上文 在了解cat指令之前&#xff0c;我们首先要了解到Linux下一切皆文件&#xff0c;在学习c语言时我们就已经了解到了 对文件输入以及读入的操作&#xff08;向显示器打印&#xff0c;从键盘读取数据&#xff09;&#xff0c;对于Linux下文件的操作&#xff0c;也是…
阅读更多...
houdini xyzdist primuv 实现按路径走

houdini xyzdist primuv 实现按路径走

2. meause distance v 0; add popforce
阅读更多...
关于Linux Docker springboot jar 日志时间不正确 问题解决

关于Linux Docker springboot jar 日志时间不正确 问题解决

使用Springboot项目的jar&#xff0c;制作了一个Docker镜像&#xff0c;启动该镜像后发现容器和容器中的Springboot 项目的日志时间不正确。 解决 查看容器时间命令为&#xff1a; docker exec 容器id date 1. 容器与宿主机同步时间 在启动镜像时候把操作系统的时间通过&q…
阅读更多...
Mac OS下应用Python+Selenium实现web自动化测试

Mac OS下应用Python+Selenium实现web自动化测试

在Mac环境下应用PythonSelenium实现web自动化测试 在这个过程中要注意两点&#xff1a; 1.在终端联网执行命令“sudo pip install –U selenium”如果失败了的话&#xff0c;可以尝试用命令“sudo easy_install selenium”来安装selenium; 2.安装好PyCharm后新建project&…
阅读更多...
QT:自定义控件（Connect使用，子控件连接）

QT:自定义控件（Connect使用，子控件连接）

自定义控件封装&#xff1a; 1.添加新文件&#xff08;设计师界面类&#xff09;&#xff0c;创建子页面 &#xff0c;放自己想要的控件 2.在主页面中使用子控件 :新建一个widget-![在这里插入图片描述](https://img-blog.csdnimg.cn/95ed8015343e4c56a3914853950eff4c.png#pi…
阅读更多...
TiDB 源码编译之 TiFlash 篇

TiDB 源码编译之 TiFlash 篇

作者&#xff1a; ShawnYan 原文来源&#xff1a; https://tidb.net/blog/5f3fe44d 导言 TiFlash 从去年四月一日开源至今已经过去将近一年半&#xff0c;这段时间里 TiFlash 从 v6.0.0-DMR 升级到了 v7.3.0-DMR &#xff0c;并增加了若干新特性&#xff0c;比如支持 …
阅读更多...
速通蓝桥杯嵌入式省一教程：（五）用按键和屏幕实现嵌入式交互系统

速通蓝桥杯嵌入式省一教程：（五）用按键和屏幕实现嵌入式交互系统

一个完整的嵌入式系统&#xff0c;包括任务执行部分和人机交互部分。在前四节中&#xff0c;我们已经讲解了LED、LCD和按键&#xff0c;用这三者就能够实现一个人机交互系统&#xff0c;也即搭建整个嵌入式系统的框架。在后续&#xff0c;只要将各个功能加入到这个交互系统中&a…
阅读更多...
最新文章

Copyright @ 2022~2023