C++11中std::future的使用
C++11中的std::future是一个模板类。std::future提供了一种用于访问异步操作结果的机制。std::future所引用的共享状态不能与任何其它异步返回的对象共享(与std::shared_future相反)( std::future references shared state that is not shared with any other asynchronous return objects (as opposed to std::shared_future))。一个future是一个对象,它可以从某个提供者的对象或函数中检索值,如果在不同的线程中,则它可以正确地同步此访问(A future is an object that can retrieve a value from some provider object or function, properly synchronizing this access if in different threads)。
有效的future是与共享状态(shared state)关联的future对象,可以通过调用以下函数(provider)来构造future对象:std::async、std::promise::get_future、std::packaged_task::get_future。future对象仅在它们是有效时才有用。
std::aysnc介绍参考:https://blog.csdn.net/fengbingchun/article/details/104133494
std::promise介绍参考:https://blog.csdn.net/fengbingchun/article/details/104124174
std::packaged_task介绍参考:https://blog.csdn.net/fengbingchun/article/details/104127352
模板类std::future成员函数包括:
1. 构造函数:(1).不带参数的默认构造函数,此对象没有共享状态,因此它是无效的,但是可以通过移动赋值的方式将一个有效的future值赋值给它;(2).禁用拷贝构造;(3).支持移动构造。
2. 析构函数:销毁future对象,它是异常安全的。
3. get函数:(1).当共享状态就绪时,返回存储在共享状态中的值(或抛出异常)。(2).如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪。(3).当共享状态就绪后,则该函数将取消阻塞并返回(或抛出)释放其共享状态,这使得future对象不再有效,因此对于每一个future共享状态,该函数最多应被调用一次。(4).std::future<void>::get()不返回任何值,但仍等待共享状态就绪并释放它。(5).共享状态是作为原子操作(atomic operation)被访问。
4. operator=:(1).禁用拷贝赋值。(2).支持移动赋值:如果在调用之前,此对象是有效的(即它已经访问共享状态),则将其与先前已关联的共享状态解除关联。如果它是与先前共享状态关联的唯一对象,则先前的共享状态也会被销毁。
5. share函数:获取共享的future,返回一个std::shared_future对象,该对象获取future对象的共享状态。future对象将不再有效。
6. valid函数:检查共享状态的有效性,返回当前的future对象是否与共享状态关联。一旦调用了std::future::get()函数,再调用此函数将返回false。
7. wait函数:(1).等待共享状态就绪。(2).如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪。(3).当共享状态就绪后,则该函数将取消阻塞并void返回。
8. wait_for函数:(1).等待共享状态在指定的时间内(time span)准备就绪。(2). 如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪或已达到设置的时间。(3).此函数的返回值类型为枚举类future_status。此枚举类有三种label:ready:共享状态已就绪;timeout:在指定的时间内未就绪;deferred:共享状态包含了一个延迟函数(deferred function)。
9. wait_until函数:(1). 等待共享状态在指定的时间点(time point)准备就绪。(2). 如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪或已达到指定的时间点。(3).此函数的返回值类型为枚举类future_status。
详细用法见下面的测试代码,下面是从其他文章中copy的测试代码,部分作了调整,详细内容介绍可以参考对应的reference:
#include "future.hpp"
#include <iostream>
#include <future>
#include <chrono>
#include <utility>
#include <thread>namespace future_ {///
// reference: http://www.cplusplus.com/reference/future/future/
int test_future_1()
{
{ // constructor/get/operator=auto get_value = []() { return 10; };std::future<int> foo; // default-constructedstd::future<int> bar = std::async(get_value); // move-constructedint x = bar.get();std::cout << "value: " << x << '\n'; // 10//int x2 = bar.get(); // crash, 对于每个future的共享状态,get函数最多仅被调用一次//std::cout << "value: " << x2 << '\n';std::future<int> foo2(std::async(get_value));std::cout << "value: " << foo2.get() << '\n'; // 10
}{ // sharestd::future<int> fut = std::async([]() { return 10; });std::shared_future<int> shfut = fut.share();//std::cout << "value: " << fut.get() << '\n'; // crash, 执行完fut.share()后,fut对象将变得无效std::cout << "fut valid: " << fut.valid() << '\n';// 0// shared futures can be accessed multiple times:std::cout << "value: " << shfut.get() << '\n'; // 10std::cout << "its double: " << shfut.get() * 2 << '\n'; // 20, 对于std::shared_future对象,get函数可以被多次访问
}{ // validstd::future<int> foo, bar;foo = std::async([]() { return 10; });bar = std::move(foo);if (foo.valid()) std::cout << "foo's value: " << foo.get() << '\n';else std::cout << "foo is not valid\n"; // foo is not validif (bar.valid()) std::cout << "bar's value: " << bar.get() << '\n'; // 10else std::cout << "bar is not valid\n";
}{ // waitauto is_prime = [](int x) {for (int i = 2; i < x; ++i) if (x%i == 0) return false;return true;};// call function asynchronously:std::future<bool> fut = std::async(is_prime, 194232491);std::cout << "checking...\n";fut.wait();std::cout << "\n194232491 ";if (fut.get()) // guaranteed to be ready (and not block) after wait returnsstd::cout << "is prime.\n";elsestd::cout << "is not prime.\n";
}{ // wait_forauto is_prime = [](int x) {for (int i = 2; i < x; ++i) if (x%i == 0) return false;return true;};// call function asynchronously:std::future<bool> fut = std::async(is_prime, 700020007);// do something while waiting for function to set future:std::cout << "checking, please wait";std::chrono::milliseconds span(100);while (fut.wait_for(span) == std::future_status::timeout) // 可能多次调用std::future::wait_for函数std::cout << '.';bool x = fut.get(); // retrieve return valuestd::cout << "\n700020007 " << (x ? "is" : "is not") << " prime.\n";
}return 0;
}///
// reference: https://en.cppreference.com/w/cpp/thread/future
int test_future_2()
{// future from a packaged_taskstd::packaged_task<int()> task([] { return 7; }); // wrap the functionstd::future<int> f1 = task.get_future(); // get a futurestd::thread t(std::move(task)); // launch on a thread// future from an async()std::future<int> f2 = std::async(std::launch::async, [] { return 8; });#ifdef _MSC_VER// future from a promisestd::promise<int> p;std::future<int> f3 = p.get_future();std::thread([&p] { p.set_value_at_thread_exit(9); }).detach(); // gcc 4.9 don't support this function
#endifstd::cout << "Waiting..." << std::flush;f1.wait();f2.wait();
#ifdef _MSC_VERf3.wait();
#endifstd::cout << "Done!\nResults are: " << f1.get() << ' ' << f2.get() << ' '
#ifdef _MSC_VER<< f3.get()
#endif<< '\n';t.join();return 0;
}///
// reference: https://thispointer.com/c11-multithreading-part-8-stdfuture-stdpromise-and-returning-values-from-thread/
void initiazer(std::promise<int> * promObj)
{std::cout << "Inside Thread" << std::endl;promObj->set_value(35);
}int test_future_3()
{std::promise<int> promiseObj;std::future<int> futureObj = promiseObj.get_future();std::thread th(initiazer, &promiseObj);std::cout << "value: " << futureObj.get() << std::endl;th.join();// If std::promise object is destroyed before setting the value the calling get() function on associated std::future object will throw exception.// A part from this, if you want your thread to return multiple values at different point of time then// just pass multiple std::promise objects in thread and fetch multiple return values from thier associated multiple std::future objects.return 0;
}} // namespace future_
GitHub:https://github.com/fengbingchun/Messy_Test
C++11中std::future的使用相关推荐
- C++/C++11中std::string用法汇总
C++/C++11中std::string是个模板类,它是一个标准库.使用string类型必须首先包含<string>头文件.作为标准库的一部分,string定义在命名空间std中. st ...
- C++11中std::async的使用
C++11中的std::async是个模板函数.std::async异步调用函数,在某个时候以Args作为参数(可变长参数)调用Fn,无需等待Fn执行完成就可返回,返回结果是个std::future对 ...
- C++11中std::packaged_task的使用
C++11中的std::packaged_task是个模板类.std::packaged_task包装任何可调用目标(函数.lambda表达式.bind表达式.函数对象)以便它可以被异步调用.它的返回 ...
- C++11中std::shared_future的使用
C++11中的std::shared_future是个模板类.与std::future类似,std::shared_future提供了一种访问异步操作结果的机制:不同于std::future,std: ...
- C语言中task的用法,C++11中std::packaged_task的使用详解
C++11中的std::packaged_task是个模板类.std::packaged_task包装任何可调用目标(函数.lambda表达式.bind表达式.函数对象)以便它可以被异步调用.它的返回 ...
- C++11之std::future对象使用说明
std::future介绍 在前面几篇文章中基本都用到thread对象,它是C++11中提供异步创建多线程的工具.但是我们想要从线程中返回异步任务结果,一般需要依靠全局变量:从安全角度看,有些不妥:为 ...
- C++11中std::promise的使用
C++11中的std::promise是个模板类.一个std::promise对象可以存储由future对象(可能在另一个线程中)检索的T类型的值或派生自std::exception的异常,并提供一个 ...
- 概率论中指数分布介绍及C++11中std::exponential_distribution的使用
指数分布:在深度学习中,我们经常会需要一个在x=0点处取得边界点(sharp point)的分布.为了实现这一目的,我们可以使用指数分布(exponential distribution): p(x; ...
- 概率论中高斯分布(正态分布)介绍及C++11中std::normal_distribution的使用
高斯分布:最常用的分布是正态分布(normal distribution),也称为高斯分布(Gaussian distribution): 正态分布N(x;μ,σ2)呈现经典的"钟形曲线&q ...
最新文章
- python编程高手教程_写给编程高手的Python教程(11) 深入类和对象
- MySQL_Oracle_事物的隔离级别
- oenwrt 进不了bios_win7进不了bios原因及解决办法
- JSP Servlet Mysql学生宿舍管理系统
- composer QA
- win11还原点如何设置 windows11还原点的设置方法
- 贺利坚老师汇编课程54笔记:SF符号标志SIGN FLAG
- svn服务端安装、迁移教程、Eclipse切换svn连接库
- 死锁和哲学家就餐问题
- FOI冬令营 Day1
- MFC中利用ListControl制作空表格,由键盘输入数据并保存在数组中
- 专业语音芯片MT8516 华为AM08蓝牙音箱
- 计算机系统基础-入门
- 必读论文|信息检索与推荐必读论文10篇
- mysql 重复率高字段 索引,为什么重复值高的字段不能建索引(+聚集索引和非聚集索引)...
- 人工智能与模式识别的意义(模式识别与图像处理课程作业)
- OCR营业执照识别接口
- 计算机类综合素质测评考什么,想问一下事业单位的综合素质测评是考什么内容呢?..._事业单位考试_帮考网...
- JAVA宠物托管系统计算机毕业设计Mybatis+系统+数据库+调试部署
- Phpcms:整合文档
热门文章
- Python的必学技术——Jupyter Notebook
- 数据结构和算法:(3)3.1线性表的顺序存储结构
- GitHub开源:100美元自制激光雷达
- requests.exceptions.ConnectionError: ('Connection aborted.', BadStatusLine('',))
- 在CentOS 6.6 64bit上升级GCC到4.8.2版本
- Ubuntu 14.04 64bit上查看网页中的cookies
- libcurl使用多线程下载大文件源码示例!
- byte endian(biglittle endian)
- OpenCV 像素存储
- php开发面试题---php面向对象详解(对象的主要三个特性)