17370845950

c++中如何使用std::async_c++异步执行任务并获取结果【汇总】
std::async默认策略为std::launch::deferred | std::launch::async,可能延迟或同步执行;必须显式指定std::launch::async才能确保真正异步;future需保存并调用get()/wait(),且get()仅能调用一次,异常在get时抛出,临时future析构会阻塞。

std::async 不是“开个线程就完事”,它默认行为取决于启动策略,不显式指定 std::launch::async 时可能延迟执行甚至同步调用——这是最常被忽略的坑。

std::async 默认启动策略是 std::launch::deferred | std::launch::async

这意味着:系统可自由选择立即异步执行,或推迟到 get() / wait() 时才同步执行。你写的是“异步调用”,但实际可能是“假装异步”。

  • 想确保真正并发执行,必须显式传入 std::launch::async
  • 若只传函数对象不传策略,std::async(func) 的行为不可移植,GCC、Clang、MSVC 在某些优化级别下都可能走 deferred
  • std::launch::deferred 模式下,get() 会立刻同步执行并返回结果,无任何并发;此时 wait_for(...) 永远返回 std::future_status::deferred

std::future::get() 只能调用一次

调用后 future 状态变为“已获取”,再次调用会抛出 std::future_error(错误码为 std::future_errc::no_statestd::future_errc::future_already_retrieved)。

  • 常见误操作:auto res = f.get(); auto res2 = f.get(); → 第二行崩溃
  • 若需多次访问结果,应把 get() 结果存为变量,或改用 std::shared_future
  • std::shared_future 支持多线程多次 get(),但需由 std::future::share() 构造:auto sf = f.share();

异常传播:async 内部抛异常,get() 会 rethrow

std::async 包裹的函数若抛异常,不会终止程序,而是被捕获并存储在 future 对象中;直到调用 get() 才原样抛出。

  • 这既是优点(避免线程猝死),也是陷阱(异常被静默吞掉,直到 get 才暴露)
  • 若忘记调用 get()wait(),异常永远不会浮现,还可能导致资源泄漏(如 future 析构时未取结果,C++11 规定会阻塞等待完成,但异常仍被丢弃)
  • 安全写法:始终在作用域结束前调用 get()wait(),或用 RAII 封装(例如自定义 scoped_future 类)

生命周期管理:future 必须存活到任务完成

std::async 返回的 std::future 管理后台任务的生命周期。如果 future 提前析构且任务尚未完成,析构行为取决于启动策略:

  • std::launch::async:future 析构会阻塞,等待任务结束(C++11 起强制要求)
  • std::launch::deferred:future 析构不执行任务,任务永远丢失
  • 因此,不要让 future 成为临时对象然后丢弃:std::async(std::launch::async, []{ /*...*/ }); 是危险的——任务虽启动,但 future 立即销毁,主线程可能在任务完成前就退出
#include 
#include 
#include 

int heavy_work() {
    std::this_thread::sleep_for(std::chrono::seconds(2));
 

return 42; } int main() { // ✅ 正确:显式 async 策略 + 保存 future + 主动 get auto fut = std::async(std::launch::async, heavy_work); std::cout << "waiting...\n"; int result = fut.get(); // 阻塞直到完成 std::cout << "result = " << result << "\n"; // ❌ 危险:临时 future,析构时阻塞,但意图不明确 // std::async(std::launch::async, []{ std::this_thread::sleep_for(1s); }); return 0; }

真正麻烦的不是语法,而是 launch 策略的隐式性、future 生命周期与异常传播的耦合——这三个点没对齐,std::async 就会从便利工具变成隐蔽的竞态/阻塞源。