C++11的std::async 和std::future

std::future

　　std::future是一个非常有用也很有意思的东西，简单说std::future提供了一种访问异步操作结果的机制。从字面意思来理解，它表示未来，我觉得这个名字非常贴切，因为一个异步操作我们是不可能马上就获取操作结果的，只能在未来某个时候获取，但是我们可以以同步等待的方式来获取结果，可以通过查询future的状态（future_status）来获取异步操作的结果。future_status有三种状态：

• deferred：异步操作还没开始
• ready：异步操作已经完成
• timeout：异步操作超时

获取future结果有三种方式：get、wait、wait_for，其中

• get：等待异步操作结束并返回结果，
• wait：只是等待异步操作完成，没有返回值，
• wait_for：是超时等待返回结果。 

std::async

std::async的原型async(std::launch::async | std::launch::deferred, f, args...)，第一个参数是线程的创建策略，有两种策略，默认的策略是立即创建线程：

• std::launch::async：在调用async就开始创建线程。
• std::launch::deferred：延迟加载方式创建线程。调用async时不创建线程，直到调用了future的get或者wait时才创建线程。

第二个参数是线程函数，第三个参数是线程函数的参数。

#include<iostream>
#include<thread>
#include<string>
#include<vector>
#include<list>
#include<mutex>
#include<future>
using namespace std;
int mythread() //线程入口函数
{
cout << "mythread start" << "threadid= " << std::this_thread::get_id() << endl; //打印线程id
std::chrono::milliseconds dura(5000); //定一个5秒的时间
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;
std::future<int> result = std::async(std::launch::async, mythread);//std::launch::deferred时进入std::future_status::deferred
cout << "continue....." << endl;
//枚举类型
std::future_status status = result.wait_for(std::chrono::seconds(10));//等待10秒是ready状态，1秒是timeout
if (status == std::future_status::deferred)
{
//线程被延迟执行了，系统资源紧张
//cout << result.get() << endl; //此时采取调用mythread()
//result.wait();
}
else if (status == std::future_status::timeout)//
{
//超时：表示线程还没执行完；我想等待你1秒，希望你返回，你没有返回，那么 status = timeout
//线程还没执行完
cout << "超时：表示线程还没执行完!" << endl;
}
else if (status == std::future_status::ready)
{
//表示线程成功返回
cout << "线程成功执行完毕，返回!" << endl;
cout << result.get() << endl;
}
cout << "I love China!" << endl;
return 0;
}

void MyTest::testCls()
{
MyCls mydata;
//async（类成员函数， 类对象， 参数1， 参数2，...，返回结果）
std::future<bool> res = std::async(&MyCls::test, &mydata, hoImg, startPos， &rtnResult);
res.wait();
m_cbk(&rtnResult);
}
void MyCls：：test（Img hoImg， double startPos， int* rtnResult）
{
......
}

最后

以上就是魔幻咖啡为你收集整理的C++11的std::async 和std::future的全部内容，希望文章能够帮你解决C++11的std::async 和std::future所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。