c++11多线程编程之std::async的介绍与实例

2023-07-12 22:36:03 89

本节讨论下在C++11中怎样使用std::async来执行异步task。

C++11中引入了std::async

什么是std::async

std::async()是一个接受回调(函数或函数对象)作为参数的函数模板，并有可能异步执行它们.

template
future::type>async(launchpolicy,Fn&&fn,Args&&...args);

std::async返回一个std::future，它存储由std::async()执行的函数对象返回的值。

函数期望的参数可以作为函数指针参数后面的参数传递给std::async()。

std::async中的第一个参数是启动策略，它控制std::async的异步行为，我们可以用三种不同的启动策略来创建std::async

·std::launch::async

保证异步行为，即传递函数将在单独的线程中执行

·std::launch::deferred

当其他线程调用get()来访问共享状态时，将调用非异步行为

·std::launch::async|std::launch::deferred

默认行为。有了这个启动策略，它可以异步运行或不运行，这取决于系统的负载，但我们无法控制它。

如果我们不指定一个启动策略，其行为将类似于std::launch::async|std::launch::deferred

本节我们将使用std::launch::async启动策略

我们可以在std::async传递任何回调，如：

·函数指针

·函数对象

·lambda表达式

std::async的需求

假设我们必须从数据库和文件系统里里获取一些数据（字符串），然后需要合并字符串并打印。

在单线程中，我们这样做：

#include
#include
#include
#include

usingnamespacestd::chrono;

std::stringfetchDataFromDB(std::stringrecvData){
//确保函数要5秒才能执行完成
std::this_thread::sleep_for(seconds(5));

//处理创建数据库连接、获取数据等事情
return"DB_"+recvData;
}

std::stringfetchDataFromFile(std::stringrecvData){
//确保函数要5秒才能执行完成
std::this_thread::sleep_for(seconds(5));

//处理获取文件数据
return"File_"+recvData;
}

intmain(){
//获取开始时间
system_clock::time_pointstart=system_clock::now();

//从数据库获取数据
std::stringdbData=fetchDataFromDB("Data");

//从文件获取数据
std::stringfileData=fetchDataFromFile("Data");

//获取结束时间
autoend=system_clock::now();

autodiff=duration_cast(end-start).count();
std::cout<<"TotalTimetaken="<
std::async()做如下的事情
·自动创建一个线程(或从内部线程池中挑选)和一个promise对象。
·然后将std::promise对象传递给线程函数，并返回相关的std::future对象
·当我们传递参数的函数退出时，它的值将被设置在这个promise对象中，所以最终的返回值将在std::future对象中可用
现在改变上面的例子，使用std::async异步地从数据库中获取数据
#include
#include
#include
#include
#include

usingnamespacestd::chrono;

std::stringfetchDataFromDB(std::stringrecvData){
//确保函数要5秒才能执行完成
std::this_thread::sleep_for(seconds(5));

//处理创建数据库连接、获取数据等事情
return"DB_"+recvData;
}

std::stringfetchDataFromFile(std::stringrecvData){
//确保函数要5秒才能执行完成
std::this_thread::sleep_for(seconds(5));

//处理获取文件数据
return"File_"+recvData;
}

intmain(){
//获取开始时间
system_clock::time_pointstart=system_clock::now();

std::futureresultFromDB=std::async(std::launch::async,fetchDataFromDB,"Data");

//从文件获取数据
std::stringfileData=fetchDataFromFile("Data");

//从DB获取数据
//数据在future对象中可获取之前，将一直阻塞
std::stringdbData=resultFromDB.get();

//获取结束时间
autoend=system_clock::now();

autodiff=duration_cast(end-start).count();
std::cout<<"TotalTimetaken="<fileResult=std::async(DataFetcher(),"Data");
用lambda函数作为回调调用std::async
std::futureresultFromDB=std::async([](std::stringrecvdData){

std::this_thread::sleep_for(seconds(5));
//处理创建数据库连接、获取数据等事情
return"DB_"+recvdData;

},"Data");
总结
到此这篇关于c++11多线程编程之std::async的文章就介绍到这了,更多相关c++11多线程编程std::async内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

c++11多线程编程之std::async的介绍与实例

热门推荐

随机推荐