17370845950

std::future和std::promise是C++11提供的单次异步值传递机制：promise设值/异常，future阻塞获取；需配对使用，仅能调用一次get()和set_*，支持超时等待与异常传播。

std::future 和 std::promise 是 C++11 引入的用于线程间传递单次值的配套机制，核心用途是实现异步任务的结果获取与主动设置。它们不直接管理线程，而是提供一种“结果通道”：一个线程通过 std::promise 设置结果，另一个线程通过关联的 std::future 等待并获取该结果。

基本配对用法：一设一取

std::promise 和 std::future 必须成对出现，通过 get_future() 建立绑定。promise 负责写入（set_value、set_exception），future 负责读取（get() 会阻塞直到有值）。

常见写法：

• 创建 std::promise p;，再调用 auto f = p.get_future();
• 在另一线程中调用 p.set_value(42);（或 p.set_exception(...)）
• 主线程调用 f.get(); —— 若尚未设置，会阻塞；设置后立即返回值（且只能调用一次）

配合 std::thread 实现手动异步任务

不同于 std::async 自动封装，用 promise + thread 可更灵活地控制执行时机和上下文。

示例场景：启动一个后台计算，完成后通知主线程

• 在主线程声明 std::promise calc_promise; 和 auto result_fut = calc_promise.get_future();
• 启动新线程，把 calc_promise 按值或移动传入（注意线程安全：promise 不可拷贝，需 move 或引用传递）
• 工作线程完成计算后，调用 promise.set_value(x);
• 主线程调用 result_fut.get(); 获取结果（自动等待、自动释放资源）

支持异常传递与超时等待

future 不仅能传值，还能传异常，使错误处理自然融入异步流：

• 工作线程中捕获异常后，调用 p.set_exception(std::current_exception());
• 主线程调用 f.get() 时，该异常会被重新抛出
• 若不想永久阻塞，可用 f.wait_for(std::chrono::seconds(3)) 判断是否就绪，或 f.wait_until(...)
• f.valid() 可检查 future 是否关联有效 promise（防止多次 get 或空 future）

std::packaged_task：更简洁的异步封装

如果目标是“把一个可调用对象包装成带 future 的异步任务”，std::packaged_task 是更直接的选择——它内部已绑定 promise/future，省去手动配对。

• 定义：std::packaged_task task([](int a, int b) { return a + b; });
• 获取 future：auto fut = task.get_future();
• 执行任务（可在任意线程）：task(3, 4); → 此时 future 就绪
• 主线程调用 fut.get(); 得到 7

不复杂但容易忽略：promise 和 future 是一次性使用的，get() 后 future 失效；promise 只能 set 一次，重复调用 set_* 会抛出 std::future_error。合理搭配 move 语义和 RAII，就能写出清晰可控的异步通信逻辑。