C++并发 std::async()

• 1. std::async()
• • 1.1 参数
  • 1.2 执行
  • 1.3 返回
• 2. 代码

对于是异步执行还是同步执行，由第一个参数的执行策略决定：
（1）std::launch::async 传递的可调用对象异步执行；
（2）std::launch::deferred 传递的可调用对象同步执行；
（3）std::launch::async | std::launch::deferred 可以异步或是同步，取决于操作系统，我们无法控制；
（4）如果我们不指定策略，即第一个参数缺省，则相当于（3）。

第二个参数接收一个可调用对象（仿函数、lambda表达式、类成员函数、普通函数…）作为参数，并且异步或是同步执行他们。

第三个及以后的参数，与std::thread类似，具体参考 C++并发 std::thread 这一篇内容。

我们可以使用 get、wait、wait_for、wait_until 等待执行结束，区别是get可以获得执行的结果：

（1）如果选择异步执行策略，调用get时，如果异步执行没有结束，get会阻塞当前调用线程，直到异步执行结束并获得结果，如果异步执行已经结束，不等待直接获取执行结果；
（2）如果选择同步执行策略，只有当调用get函数时，同步调用才真正执行，这也被称为函数调用被延迟。

返回结果std::future的状态：
（1）deffered：异步操作还没有开始；
（2）ready：异步操作已经完成；
（3）timeout：异步操作超时。

#include 
#include 

int find_the_answer_to_ltuae(int a, int b)
{
    std::this_thread::sleep_for(std::chrono::milliseconds(5000));
    std::cout << "thread id: " << std::this_thread::get_id() << ", find_the_answer_to_ltuae" << std::endl;
    return a + b;
}

void do_other_stuff()
{
    std::cout << "thread id: " << std::this_thread::get_id() << ", do_other_stuff" << std::endl;
}

int main()
{
    std::cout << "Main thread id: " << std::this_thread::get_id() << std::endl;

    std::future the_answer = std::async(find_the_answer_to_ltuae, 10, 20);

    do_other_stuff();

    std::this_thread::sleep_for(std::chrono::milliseconds(10000));

    std::cout << "answer is " << the_answer.get() << std::endl;
}

运行效果：