c++ async 使用详解，创建异步任务的多种方法
c++ async 使用详解
std::async
-
头文件
#include <future>。 -
函数原型：
template<class Function, class... Args> std::future<std::invoke_result_t<std::decay_t<Function>,std::decay_t<Args>...>>async(std::launch policy, Function&& f, Args&&... args);template<class Function, class... Args> std::future<std::invoke_result_t<std::decay_t<Function>,std::decay_t<Args>...>>async(Function&& f, Args&&... args); // 等同于以 std::launch::async | std::launch::deferred 策略调用上面的函数policy：以何种策略调用可调用对象 f，可以为以下三种：std::launch::async：以异步的方式调用 f，即必须另外开启专属的线程，在其上运行 f。std::launch::deferred：在返回的 std::future 上调用了非定时等待函数，即 wait 或者 get 时，才执行 f。std::launch::async | std::launch::deferred：可能异步运行 f 或者直到调用 wait 或者 get 时才运行，取决于系统的负载，无法人为控制。
f：要调用的可调用对象。args：传递给 发的参数。- 返回值：std::future 对象，在其上调用 wait 可以等待 f 完成，调用 get 可以等待并获取 f 的返回值。
-
作用：以异步或者同步的调用可调用对象 f，并可以通过返回的 std::future 对象获取 f 的返回值。
使用注意
-
如果没有任何对象接收 std::sync 的返回值，即使指定了 std::launch::async 策略，std::future 的析构函数也会阻塞直到整个调用完成。
-
示例如下：
// 临时量即 std::future 的析构函数等待睡眠完成。 std::async(std::launch::async, []{ std::this_thread::sleep_for(10ms); }); // 在睡眠完成之前，本行代码不会得到运行 std::async(std::launch::async, []{ printf("xx"); }); -
只有从 std::async 获取的 std::future 对象其析构函数会阻塞，以其他方式获得的 std::future 对象则不会。
示例1 函数作为参数
#include <stdio.h>
#include <thread>
#include <future>
#include <chrono>int f1(int n, int& b)
{for (int i = 0; i < 3; ++i) {printf("async is running\n");++n;++b;std::this_thread::sleep_for(std::chrono::milliseconds(10));}printf("n is %d, b is %d\n", n, b);return n + b;
}int main()
{int n = 0;int b = 0;// n 按值传递，b 按引用传递auto f = std::async(std::launch::async, f1, n, std::ref(b));int ret = f.get();printf("result is %d\n", ret);return 0;
}
示例2 lamba 作为参数
#include <stdio.h>
#include <thread>
#include <future>
#include <chrono>int main()
{auto f = std::async([]() -> int {for (int i = 0; i < 3; ++i) {printf("async is running\n");std::this_thread::sleep_for(std::chrono::milliseconds(10));}return 100;});int ret = f.get();printf("result is %d\n", ret);return 0;
}
示例3 std::function 作为参数
#include <stdio.h>
#include <thread>
#include <future>
#include <chrono>
#include <functional>int main()
{std::function<int(void)> func = []() -> int {for (int i = 0; i < 3; ++i) {printf("async is running\n");std::this_thread::sleep_for(std::chrono::milliseconds(10));}return 100;};auto f = std::async(func);int ret = f.get();printf("result is %d\n", ret);return 0;
}