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

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

发布时间 - 2025-12-31 00:00:00 点击率：次

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() 不返回值，但仍会传播异常，也仅能调用一次

复杂点在于：异常是否发生，完全取决于你有没有调用 get()。哪怕异步函数里抛了异常，只要你不 get()，程序就不会崩，但你也永远不知道它失败了。

# ai # c++ # 异步任务 # red # throw # void # 循环 # 值类型 # 线程 # 线程生命周期 # 并发 # 对象 # promise # 异步 # 抛出 # 这是 # 多个 # 返回值 # 仍需 # 的是 # 也不 # 还没 # 首次 # 就不

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251813 】【 AI营销90571 】

上一篇：利用GitHub Pages等静态站点托管服务能否完全取代传

下一篇：利用WebMan技术实现在线咨询和客服平台

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：利用GitHub Pages等静态站点托管服务能否完全取代传

下一篇：利用WebMan技术实现在线咨询和客服平台