首页 / 操作系统 / Linux / C++并发编程 异步任务

C++并发编程 异步任务

异步任务 std::async

（1） std::async 会返回一个 std::future 对象, 这个对象持有最终计算出来的结果. 当需要这个值时, 只需要调用对象的get（）成员函数. 并且直到“期望”状态为就绪的情况下, 线程才会阻塞; 之后，返回计算结果. std::future<int> answer = std::async（[] {std::stringstream stm;stm << "future id:" << std::this_thread::get_id（） << std::endl;std::cout << stm.str（）;int sum = 0;for （int i = 1; i <= 100; i++）{sum += i;std::cout << i << " ";}std::cout << std::endl;std::this_thread::sleep_for（std::chrono::seconds（1））;// 增加延迟（1s）return sum;}）;std::stringstream stm;stm << "main id:" << std::this_thread::get_id（） << std::endl;std::cout << stm.str（）;std::cout << "answer is: " << answer.get（） << std::endl; // 此时会被阻塞, 直到异步任务返回std::cout << "tag 2" << std::endl;（2） std::async 允许通过添加额外的调用参数, 向函数传递额外的参数.
如果第一个参数是一个指向成员函数的指针, 第二个参数提供有这个函数成员类的具体对象（可以通过指针, 或者包装在 std::ref 中）, 剩余的参数可作为成员函数的参数传入.
否则, 随后的所有参数将作为函数的参数, 或作为指定可调用对象的第一个参数. 比如 std::thread, 当参数为右值（rvalues）时, 拷贝操作将使用移动的方式转移原始数据. 这就允许使用“只移动”类型作为函数对象和参数.class XFun {public:XFun（） {}~XFun（） {}void f（const std::string& str） {std::stringstream stm;stm << "f called. " << this << "-->" << str << std::endl;std::cout << stm.str（）;}std::string g（const std::string& str） {std::stringstream stm;stm << str << "[--> add by function g] " << this;return stm.str（）;}//XFun& operator=（const XFun&） = delete;//XFun（const XFun&） = delete;void operator（）（const std::string& str） {std::stringstream stm;stm << "operator（） called. " << this << "-->" << str << std::endl;std::cout << stm.str（）;}};XFun x;std::cout << "addr of x:" << &x << std::endl;std::async（&XFun::f, &x, std::string（"test f（）"））;std::future<std::string> f2 = std::async（&XFun::g, x, std::string（"test g（） temp"））; // 创建一个 x 对象的副本传入, 删除赋值函数后, 将不能编译std::async（std::ref（x）, std::string（"test operator（）"））;std::async（XFun（）, std::string（"test operator（） temp"））; // 创建一个 XFun 的临时对象传入std::cout << f2.get（） << std::endl;（3） 默认情况下, std::async 会启动一个新线程来完成任务, 但是也可以指定额外的执行方式:
std::launch::defered 指定等到 wait 或 get 被调用时才执行.
std::launch::async 指定必须到独立的线程中执行.
默认为: std::launch::defered | std::launch::asyncauto f3 = std::async（std::launch::deferred, [] {std::stringstream stm;stm << "f3 called. TID:" << std::this_thread::get_id（） << std::endl;std::cout << stm.str（）;}）;auto f4 = std::async（std::launch::async, [] {std::stringstream stm;stm << "f4 called. TID:" << std::this_thread::get_id（） << std::endl;std::cout << stm.str（）;}）;std::stringstream stm;stm << "main. TID:" << std::this_thread::get_id（） << std::endl;std::cout << stm.str（）;std::this_thread::sleep_for（std::chrono::seconds（1））;f3.wait（）;本文永久更新链接地址：http://www.linuxidc.com/Linux/2016-12/138003.htm