c++怎么使用std::future执行异步操作_c++ 线程返回值获取与异常捕获【实战】_技术教程

std::async是最安全获取std::future的方式，需显式指定std::launch::async确保异步执行；std::promise适用于精细控制结果设置，但只能调用一次set_value/set_exception，且未设置时get()抛出broken_promise异常。

std::async 启动异步任务并获取 std::future

直接用 std::async 是最常用、最安全的获取 std::future 的方式。它自动管理线程生命周期，避免裸线程泄漏或提前析构问题。

关键点：默认启动策略是 std::launch::async | std::launch::deferred，这意味着可能延迟执行（比如调用 get() 时才运行），也可能立即异步执行——行为不保证，除非显式指定策略。

要确保真正异步执行，必须传入 std::launch::async，否则在某些编译器（如 MSVC Debug 模式）下会退化为同步调用，get() 不阻塞但也不并发
函数返回值类型必须能被 std::future 包装；若返回 void，对应的是 std::future，仍需调用 get() 等待完成（尤其为了捕获异常）
不能忽略返回的 std::future 对象：若未调用 get() 或 wait()，且其析构时内部状态仍为“未就绪”，则析构会阻塞直到任务结束（C++11 起标准强制要求）

auto fut = std::async(std::launch::async, []() -> int {
    std::this_thread::sleep_for(std::chrono::seconds(2));
    return 42;
});
// 此处可做其他工作
int result = fut.get(); // 阻塞等待，获取返回值，同时 rethrow 异常

从 std::promise 获取 std::future 并手动设值

当需要精细控制何时“完成”、或跨线程/回调中设置结果时，std::promise 更灵活。它和 std::future 是一对“生产-消费”端，通过共享状态关联。

常见误用：多个线程对同一个 std::promise 多次调用 set_value() 或 set_exception() —— 这是未定义行为，只能调用一次。

std::promise 对象本身不可拷贝，只能移动；但它的 get_future() 返回的 std::future 可以拷贝（多个 future 共享同一状态）
若 promise 析构前未调用任何 set 方法，其关联的 future 在 get() 时会抛出 std::future_error（错误码 std::future_errc::broken_promise）
在线程中捕获异常后，应调用 promise.set_exception(std::current_exception())，而非直接 throw —— 否则异常会终止线程，无法传递到 future 端

std::promise prom;
auto fut = prom.get_future();

std::thread t([&prom]() {
    try {
        throw std::runtime_error("oops");
    } catch (...) {
        prom.set_exception(std::current_exception()); // 正确传递异常
    }
});
t.detach(); // 注意：此处仅作示意；实际应 join 或管理生命周期

// 主线程中
try {
    auto x = fut.get(); // 抛出 runtime_error
} catch (const std::exception& e) {
    std::cout << e.what() << "\n"; // 输出: oops
}

std::future::wait_for / wait_until 判断超时与状态

不能只靠 get() 等待，很多场景需要非阻塞轮询或带超时的等待。这时要用 wait_for() 或 wait_until()，它们返回 std::future_status 枚举。

注意：wait_for() 的超时时间是相对当前时间的，不是从 future 创建起算；且即使返回 std::future_status::timeout，future 状态仍可能在之后变为 ready —— 它只是“此刻还没好”，不代表永远等不到。

返回 std::future_status::ready 后，仍需调用 get() 才能取值或传播异常；不调用 get() 就直接丢弃 future，会导致析构时阻塞（见上一节）
使用 std::chrono::steady_clock 相关时间点更可靠，避免系统时间被修改影响 wait_until
在循环中反复调用 wait_for 做轮询时，注意避免忙等（例如加小延时），或改用条件变量 + shared state 组合

auto fut = std::async(std::launch::async, []{
    std::this_thread::sleep_for(std::chrono::seconds(3));
    return 123;
});

auto status = fut.wait_for(std::chrono::seconds(1));
if (status == std::future_status::timeout) {
    std::cout << "still running...\n";
} else if (status == std::future_status::ready) {
    std::cout << "result: " << fut.get() << "\n"; // 必须调用 get()
}

异常捕获必须通过 get()，且仅发生一次

std::future 的异常传递机制是“一次性消费”：只有首次调用 get() 会 rethrow 存储的异常；后续再调用会抛出 std::future_error（std::future_errc::no_state 或类似，取决于实现）。

这是最容易忽略的陷阱：写两次 fut.get()，第二次必然崩溃，而且错误信息不直观。

如果 future 已经调用过 get()（无论成功还是异常），就不能再用于 wait_for、wait_until 或再次 get() —— 状态已销毁
想多次检查状态，只能用 wait_for + std::future_status::ready，但最终取值/异常仍只能靠一次 get()
对于 std::future，get() 不返回值，但仍会传播异常，也仅能调用一次