C++多线程——async、packages_task、promise-526互联

异步编程 `async` 、`future`

基本概念和使用：

异步执行函数：std::async 可以异步执行一个函数，这意味着函数将在后台线程中执行，而当前线程可以继续执行其他任务。
返回值获取：你可以获得函数的返回值，或者得到一个 std::future 对象，它允许你在将来的某个时刻获取函数的结果。
线程池使用：具体的线程管理是由 C++ 标准库的实现来处理的，它可以使用线程池来执行函数，以提高性能和资源利用率。

一个简单的使用示例说明 std::async 的使用:


#include <iostream>
#include <future>

int add(int a, int b) {
    return a + b;
}

int main() {

    std::future<int> result = std::async(std::launch::async, add, 1, 2);

    // 执行一些其它函数

    // 获取函数的返回值
    int sum = result.get();

    std::cout << "sum = " << sum << std::endl;

    return 0;
}

我们使用 std::launch::async 标记来显式请求在新线程中执行函数，但具体的线程管理是由标准库来处理的。
result.get() 用于获取异步执行函数的结果，是阻塞的。如果子线程没用计算完，会阻塞在这里。

`packaged_task`

C++11引入，将可调用对象（函数、函数指针、lambda表达式）包装为异步任务，并可以与期望对象std::future关联，从而获取异步执行的返回值。

主要用法：

包装可调用对象：std::packaged_task 允许你将一个可调用对象（函数或函数对象）包装为一个任务。
异步执行：你可以通过调用 std::packaged_task 对象的 operator() 方法在后台线程中执行包装的可调用对象。
获取结果：std::packaged_task 与 std::future 结合使用，允许你在将来的某个时刻获取任务的执行结果。

举例使用packaged_task对可调用对象进行包装，后异步执行，返回结果：

#include <iostream>
#include <future>

int add(int a, int b) {
    return a + b;
}

int main() {
    // 创建一个 packaged_task，将 add 函数包装起来
    std::packaged_task<int(int, int)> task(add);

    // 获取与任务相关联的 future
    std::future<int> result = task.get_future();

    // 异步执行任务
    std::thread t(std::move(task), 3, 4);

    // 执行一些其他工作...

    // 获取任务的执行结果
    int sum = result.get();

    t.join();

    std::cout << "Sum: " << sum << std::endl;

    return 0;
}

`promise`

std::promise 是一种用于在一个线程中生成一个结果，并在另外一个线程中获取结果的机制。std::promise 允许一个线程承诺（promise）一个值，并提供一个与之关联的 std::future，在另一个线程中可以通过 std::future 获取该值。

以下是 std::promise 的主要概念和用法：

生成值：一个线程使用 std::promise 来生成一个值，可以是任何类型的数据（例如，整数、字符串、自定义结构等）。
提供 std::future：std::promise 提供了一个 get_future() 方法，它返回一个与该 promise 关联的 std::future 对象，可以用于在其他线程中等待获取值。
获取值：在另一个线程中，你可以使用与 promise 关联的 std::future 来等待获取值。一旦 promise 的值被设置，std::future 可以获取到该值。

以下示例说明使用promise设置值并获取值的过程：

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

void setValue(std::promise<int>& p) {
    std::this_thread::sleep_for(std::chrono::seconds (2));
    p.set_value(42);
}

int main() {

    std::promise<int> myPromise;

    std::future<int> res = myPromise.get_future();

    std::thread t(setValue, std::ref(myPromise));

    int value = res.get();

    t.join();

    std::cout << "The value is " << value << std::endl;

    return 0;
}