Chapter 4 多线程异步通信和并发计算

1. 异步通信

1.1 异步变量

promise：

promise提供存储异步通信的值 , 再通过其对象创建的future异步获得结果
promise创建的一个对象只能用一次set_value设置传递值；也只能用一次get_future()获取future对象
创建子线程时需要使用move将promise对象传给子线程

future：

future对象的get()方法会阻塞等待promise::set_value()的值

代码示例：

#include <iostream>
#include <future>
#include <thread>

using namespace std;

void TestFuture(promise<string> p)
{
    p.set_value("TestFuture value\n");
}

int main(int argc, char* argv[])
{
    promise<string> p;/*异步传输变量存储*/
    auto future{ p.get_future() };/*用来获取线程异步值获取*/
    thread th(TestFuture, move(p));

    cout << "future.get() = " << future.get();
    th.join();

    return 0;
}

1.2 异步调用函数

packaged_task：

包装函数为一个对象，可通过get_future()获取future对象

代码示例：

#include <iostream>
#include <future>
#include <thread>

using namespace std;
string TestPack(const int index)
{
    string r {__FUNCTION__};
    r += " return";
    return r;
}

int main(int argc, char* argv[])
{
    packaged_task<string(const int)> task(TestPack);
    auto result { task.get_future() };
    thread th(move(task), 100);

    cout << "result get = " << result.get();
    th.join();

    return 0;
}