怎么在C++11中使用std::async方法
本篇文章给大家分享的是有关怎么在C++11中使用std::async方法，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
让客户满意是我们工作的目标，不断超越客户的期望值来自于我们对这个行业的热爱。我们立志把好的技术通过有效、简单的方式提供给客户，将通过不懈努力成为客户在信息化领域值得信任、有价值的长期合作伙伴，公司提供的服务项目有：域名注册、雅安服务器托管、营销软件、网站建设、铜鼓网站维护、网站推广。
std::async有两个版本：
1.无需显示指定启动策略，自动选择，因此启动策略是不确定的，可能是std::launch::async，也可能是std::launch::deferred，或者是两者的任意组合，取决于它们的系统和特定库实现。
2.允许调用者选择特定的启动策略。
std::async的启动策略类型是个枚举类enum class launch，包括：
1. std::launch::async：异步，启动一个新的线程调用Fn，该函数由新线程异步调用，并且将其返回值与共享状态的访问点同步。
2. std::launch::deferred：延迟，在访问共享状态时该函数才被调用。对Fn的调用将推迟到返回的std::future的共享状态被访问时(使用std::future的wait或get函数)。
参数Fn：可以为函数指针、成员指针、任何类型的可移动构造的函数对象(即类定义了operator()的对象)。Fn的返回值或异常存储在共享状态中以供异步的std::future对象检索。
参数Args：传递给Fn调用的参数，它们的类型应是可移动构造的。
返回值：当Fn执行结束时，共享状态的std::future对象准备就绪。std::future的成员函数get检索的值是Fn返回的值。当启动策略采用std::launch::async时，即使从不访问其共享状态，返回的std::future也会链接到被创建线程的末尾。在这种情况下，std::future的析构函数与Fn的返回同步。
std::future介绍参考：https://www.jb51.net/article/179229.htm
详细用法见下面的测试代码，下面是从其他文章中copy的测试代码，部分作了调整，详细内容介绍可以参考对应的reference：
#include "future.hpp"
#include <iostream>
#include <future>
#include <chrono>
#include <utility>
#include <thread>
#include <functional>
#include <memory>
#include <exception>
#include <numeric>
#include <vector>
#include <cmath>
#include <string>
#include <mutex>
namespace future_ {
///////////////////////////////////////////////////////////
// reference: http://www.cplusplus.com/reference/future/async/
int test_async_1()
{
auto is_prime = [](int x) {
std::cout << "Calculating. Please, wait...\n";
for (int i = 2; i < x; ++i) if (x%i == 0) return false;
return true;
};
// call is_prime(313222313) asynchronously:
std::future<bool> fut = std::async(is_prime, 313222313);
std::cout << "Checking whether 313222313 is prime.\n";
// ...
bool ret = fut.get(); // waits for is_prime to return
if (ret) std::cout << "It is prime!\n";
else std::cout << "It is not prime.\n";
return 0;
}
///////////////////////////////////////////////////////////
// reference: http://www.cplusplus.com/reference/future/launch/
int test_async_2()
{
auto print_ten = [](char c, int ms) {
for (int i = 0; i < 10; ++i) {
std::this_thread::sleep_for(std::chrono::milliseconds(ms));
std::cout << c;
}
};
std::cout << "with launch::async:\n";
std::future<void> foo = std::async(std::launch::async, print_ten, '*', 100);
std::future<void> bar = std::async(std::launch::async, print_ten, '@', 200);
// async "get" (wait for foo and bar to be ready):
foo.get(); // 注：注释掉此句，也会输出'*'
bar.get();
std::cout << "\n\n";
std::cout << "with launch::deferred:\n";
foo = std::async(std::launch::deferred, print_ten, '*', 100);
bar = std::async(std::launch::deferred, print_ten, '@', 200);
// deferred "get" (perform the actual calls):
foo.get(); // 注：注释掉此句，则不会输出'**********'
bar.get();
std::cout << '\n';
return 0;
}
///////////////////////////////////////////////////////////
// reference: https://en.cppreference.com/w/cpp/thread/async
std::mutex m;
struct X {
void foo(int i, const std::string& str) {
std::lock_guard<std::mutex> lk(m);
std::cout << str << ' ' << i << '\n';
}
void bar(const std::string& str) {
std::lock_guard<std::mutex> lk(m);
std::cout << str << '\n';
}
int operator()(int i) {
std::lock_guard<std::mutex> lk(m);
std::cout << i << '\n';
return i + 10;
}
};
template <typename RandomIt>
int parallel_sum(RandomIt beg, RandomIt end)
{
auto len = end - beg;
if (len < 1000)
return std::accumulate(beg, end, 0);
RandomIt mid = beg + len / 2;
auto handle = std::async(std::launch::async, parallel_sum<RandomIt>, mid, end);
int sum = parallel_sum(beg, mid);
return sum + handle.get();
}
int test_async_3()
{
std::vector<int> v(10000, 1);
std::cout << "The sum is " << parallel_sum(v.begin(), v.end()) << '\n';
X x;
// Calls (&x)->foo(42, "Hello") with default policy:
// may print "Hello 42" concurrently or defer execution
auto a1 = std::async(&X::foo, &x, 42, "Hello");
// Calls x.bar("world!") with deferred policy
// prints "world!" when a2.get() or a2.wait() is called
auto a2 = std::async(std::launch::deferred, &X::bar, x, "world!");
// Calls X()(43); with async policy
// prints "43" concurrently
auto a3 = std::async(std::launch::async, X(), 43);
a2.wait(); // prints "world!"
std::cout << a3.get() << '\n'; // prints "53"
return 0;
} // if a1 is not done at this point, destructor of a1 prints "Hello 42" here
///////////////////////////////////////////////////////////
// reference: https://thispointer.com/c11-multithreading-part-9-stdasync-tutorial-example/
int test_async_4()
{
using namespace std::chrono;
auto fetchDataFromDB = [](std::string recvdData) {
// Make sure that function takes 5 seconds to complete
std::this_thread::sleep_for(seconds(5));
//Do stuff like creating DB Connection and fetching Data
return "DB_" + recvdData;
};
auto fetchDataFromFile = [](std::string recvdData) {
// Make sure that function takes 5 seconds to complete
std::this_thread::sleep_for(seconds(5));
//Do stuff like fetching Data File
return "File_" + recvdData;
};
// Get Start Time
system_clock::time_point start = system_clock::now();
std::future<std::string> resultFromDB = std::async(std::launch::async, fetchDataFromDB, "Data");
//Fetch Data from File
std::string fileData = fetchDataFromFile("Data");
//Fetch Data from DB
// Will block till data is available in future<std::string> object.
std::string dbData = resultFromDB.get();
// Get End Time
auto end = system_clock::now();
auto diff = duration_cast <std::chrono::seconds> (end - start).count();
std::cout << "Total Time Taken = " << diff << " Seconds" << std::endl;
//Combine The Data
std::string data = dbData + " :: " + fileData;
//Printing the combined Data
std::cout << "Data = " << data << std::endl;
return 0;
}
} // namespace future_以上就是怎么在C++11中使用std::async方法，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。
当前题目：怎么在C++11中使用std::async方法
当前链接：https://www.cdcxhl.com/article16/ggeegg.html
成都网站建设公司_创新互联，为您提供网站收录、网站策划、电子商务、静态网站、企业建站、标签优化
声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联
- 拔“云”见日，和大家聊聊云服务器的那些事 2021-02-22
- 云服务器与传统独立服务器本质区别 2022-10-02
- 云服务器能不能够免费试用？ 2022-10-03
- 云服务器搭建难不难？企业云服务器搭建流程 2022-10-12
- 免费服务器真的靠谱吗？盘点国内外免费云服务器那些坑 2022-10-08
- 选购云服务器后，可以用来干什么? 2021-02-27
- 免备案vps云服务器有哪些吸引力？ 2022-10-10
- 租用高防云服务器怎么选才靠谱？ 2022-10-09
- 云服务器哪家好？怎么选择云服务器？ 2021-03-06
- 云服务器英文缩写怎么写 2023-03-15
- 云服务器租用所具有的特点有哪些 2021-02-15
- 免备案香港服务器和非免备案云服务器有什么区别？ 2022-10-12