当前位置：首页 > 编程日记 > 正文

C++ 多线程：future 异步访问类（线程之间安全便捷的数据共享）

编程日记 2024-04-28 13:30:00

文章目录

- - future前言
  - future描述
  - future类成员使用
  - 总结

future前言

首先查看如下代码

#include <iostream>
#include <thread>
#include <future>
#include <mutex>using namespace std;void fun1(int n,int &x) {int res = 1;for (int i = n; i>1; --i) {res *=i;}cout << "Result is " << res << endl;//输出最终的结果并赋值给共享变量xx = res;
}int main()
{int x;std::thread t1(fun1,4,std::ref(x));t1.join();return 0;
}

这段代码仅拥有一个线程，但是可以很明显得看到主线程和t1线程想要共享同一个变量x,同时x是需要在t1线程进行赋值将结果返回给主线程，由主线程来获取。这样的线程之间的变量传递，我们所知道的传递方式只能是传递引用。同时仅仅传递引用是不够的，因为线程之间的变量共享需要对变量进行保护才能安全有效共享，这样就需要引入mutex互斥变量和condition_variable条件变量对共享变量进行保护。

这样会导致代码逻辑更加复杂，逻辑细节也会变得非常谨慎。这个时候我们引入future类对以上操作进行简化。

future描述

头文件 <future>
声明template< class T > class future<T&>;
简介
future类模版提供了一种异步访问操作机制如下：
- 异步操作能提供一个 std::future 对象给该异步操作的创建者。其中包括std::async 、 std::packaged_task 或 std::promise的返回值为std::future对象
- 异步操作的创建者能用各种方法查询、等待或从 std::future 提取值。若异步操作仍未提供值，则这些方法可能阻塞。如使用std::async创建的异步操作返回的future对象未获取值，那么std::async将不会退出
- 异步操作准备好发送结果给创建者时，它能通过修改链接到创建者的 std::future 的共享状态（例如std::promise::set_value）进行

future类成员使用

std::future<T>::get 获取异步操作的返回结果
get 方法等待直至 future 拥有合法结果并（依赖于使用哪个模板）获取它。它等效地调用 wait() 等待结果
这里需要简单说明下get函数的返回值，它的返回值为std::move()类型，即将之前的返回结果包括值和地址都进行赋值。如果二次尝试get，回访问到空的值和地址，报出异常std::future_error。
我们对刚开始的代码更改如下：

#include <iostream>
#include <thread>
#include <future>
#include <mutex>using namespace std;int fun1(int n) {int res = 1;for (int i = n; i>1; --i) {res *=i;}cout << "Result is " << res << endl;return res;
}int main()
{int x;//std::thread t1(fun1,4,std::ref(x));//t1.join();//我们使用异步操作，并使用get函数获取异步操作函数的合法返回值std::future<int> fu = std::async(fun1,4);x = fu.get();return 0;
}

如上代码，我们使用std::async()异步操作来创建字线程，并返回一个future类的对象，然后由future对象的get()函数来获取子线程合法的返回结果。

关于async()等异步操作将会在下一篇进行分享，这里简单描述一下：
async提供的是从子线程获取数值到主线程，如果我们想要从主线程获取数值到子线程，则需要promise异步操作
查看如下代码为我们利用promise从主线程获取数值到子线程

#include <iostream>
#include <thread>
#include <future>
#include <mutex>using namespace std;int fun1(std::future<int> &f) {int res = 1;int n = f.get();for (int i = n; i>1; --i) {res *=i;}cout << "Result is " << res << endl;return res;
}int main()
{int x;//std::thread t1(fun1,4,std::ref(x));//t1.join();std::promise<int> p;//标示f是一个需要从未来获取数值future对象std::future<int> f = p.get_future(); std::future<int> fu = std::async(std::launch::async,fun1, std::ref(f));//为f设置数值，在子线程中进行f.get()获取主线程到数值p.set_value(4);x = fu.get();cout << "Get from child " << x << endl;return 0;
}

输出结果如下:

Result is 24
Get from child 24

可以看到最终从子线程获取到了计算好的合法数值

std::future<T>::wait 阻塞线程，直到获取到可用结果

#include <iostream>
#include <future>
#include <thread>int fib(int n)
{if (n < 3) return 1;else return fib(n-1) + fib(n-2);
}int main()
{std::future<int> f1 = std::async(std::launch::async, [](){return fib(20);});std::future<int> f2 = std::async(std::launch::async, [](){return fib(25);});std::cout << "waiting...\n";//主线程在该处阻塞，直到获取到f1,f2两个线程到合法的结果f1.wait();f2.wait();std::cout << "f1: " << f1.get() << '\n';std::cout << "f2: " << f2.get() << '\n';
}

wait_for()和wait_until()两个函数成员同condition_variable中的类似，仍然是仅增加了需要等待的时间，到达等待的时间如仍然无法获取到合法的返回值即同样终止get

总结

可以看到我们在使用future的类的时候能够极为方便得实现线程之间的变量传递，达到更加便捷且更加安全的线程之间数据共享的目的。
关于future类的异步操作async,promise以及packaged_task的使用方式将后续分享。

https://www.dkcj.cn/info/5349.html

C++ 多线程：future 异步访问类（线程之间安全便捷的数据共享）

文章目录

future前言

future描述

future类成员使用

总结

相关文章：

bldc不同载波频率_广播百科频率调制

基于visual Studio2013解决面试题之0403串联字符串

MIT开放式课程“自然语言处理”介绍

怎么将对象里面部分的属性放到一个空的对象里面去

C++多线程：thread类创建线程的多种方式

C C++的编译过程详解

python queue 调试_学Python不是盲目的，是有做过功课认真去了解的

嘿嘿刚刚进来记录下

Oracle数据库查看表空间是否为自增的

C++多线程：异步操作std::async和std::promise

5如何将表格的一行数据清空_微信公众号推文中如何自定义添加表格？

基于visual Studio2013解决面试题之0901奇偶站队

联想架构调整：智能手机业务很重要

activiti5/6 系列之--BpmnModel使用

C++多线程：package_task异步调用任何目标执行操作

ICE BOX 配置，使用----第一篇

测试打桩_DNF：CEO实测旭旭宝宝红眼，打桩高达2494E，伤害超越狂人剑魂

122112_1452_Word1

C++ 多线程：时间控制

array用法 numpy_NumPy总结（基础用法）

python 字符串转 dict

rhino-java中调用javascript

HDU 2566 统计硬币

linux C 多线程编程

JavaSE replaceAll 方法

elementui datetimepicker 移动端_在 Gitee 收获 2.5K Star，前后端分离的 RuoYi 它来了

用MyEclipse开发Spring入门

带你轻而易举的学习python——八皇后问题

ubuntu18.04.1内核升级至5.0.0-25版本

输出n行杨辉三角数