C++ 实现异步任务的任务链式异步执行模型设计方案实战异步实战源码【源码】-C++-PHP中文网

std::async不能链式调用因C++17无.then()；需封装可组合异步句柄，用shared_ptr+promise+回调实现非阻塞链式执行，并确保异常透传与生命周期安全。

c++ 实现异步任务的任务链式异步执行模型设计方案实战异步实战源码【源码】

为什么 `std::async` 串成链会崩？

直接用 std::async 连续调用（比如 std::async(...).then(...)）会编译失败——C++17 标准库根本没有 .then() 成员。这是最常踩的坑：误把 std::future 当成 JS Promise 或 Rust Future 来用。

真正能链式执行的前提是自己封装一个可组合的异步句柄，核心是让前序任务的 std::future 能触发后序任务的调度，且不阻塞线程。

别在主线程里对 std::future::get() 做链式等待，这等于退化成同步调用
避免裸用 std::packaged_task + std::thread 手动管理生命周期，容易悬垂或提前析构
必须显式处理异常传递：std::future::wait_for 不会抛出前序任务的异常，得用 get() 显式触发

用 `std::shared_ptr` + `std::function` 构建可链式挂载的任务节点

链式模型的本质不是“返回 future”，而是“注册回调”。每个任务节点持有上一节点完成后的执行逻辑，并把自身结果交给下一节点——靠共享状态和延迟调用实现。

关键结构体示意：

struct TaskNode {
    std::shared_ptr<:promise>> promise_;
    std::function<void> on_complete_;
    std::function<int> work_;
};
</int></void></:promise>

work_ 是实际要异步执行的函数（无参、返回 int，可泛化为模板）
on_complete_ 是前序结果到来时触发的回调，参数即前序 promise_.get_future().get() 的值
promise_ 供本节点完成后设置结果，下游靠 promise_.get_future() 监听

这样每个节点只依赖上一节点的 std::future 就能启动，无需等待，也不需要语言级协程支持。

如何安全地把 `std::future` 转成可链式消费的句柄？

不能直接传 std::future 到另一个线程里 move（它不可拷贝，move 后原对象失效），但可以把它包装进 std::shared_ptr 并配合原子状态控制消费时机。

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

推荐做法是：用 std::shared_ptr<:future>> + 线程池回调，例如：

template<typename t typename f>
auto then(std::shared_ptr<:future>> fut, F&& callback) 
    -> std::shared_ptr<:future>()))>> {
    auto p = std::make_shared<:promise>()))>>();
    auto result_fut = std::make_shared<:future>()))>>(p->get_future());
    
    // 在线程池中等待 fut 完成并触发 callback
    thread_pool.enqueue([fut, p, cb = std::forward<f>(callback)]() mutable {
        try {
            auto val = fut->get(); // 这里可能抛异常
            p->set_value(cb(val));
        } catch (...) {
            p->set_exception(std::current_exception());
        }
    });
    return result_fut;
}
</f></:future></:promise></:future></:future></typename>

每次 then 都返回新的 std::shared_ptr<:future>>，避免裸 future 生命周期失控
异常必须用 set_exception 透传，否则下游 get() 会 terminate
不要在 then 回调里再调用 get() —— 这又变成同步阻塞了

线程池调度器里怎么避免 `std::future::wait` 空转耗 CPU？

常见错误是在线程池 worker 中轮询 fut.wait_for(1ms) == std::future_status::ready，这本质是忙等，完全违背异步初衷。

正确做法是：让任务提交者不主动 wait，而是由系统通知。C++20 前只能靠条件变量 + 状态标记模拟，例如：

struct AsyncFuture {
    std::mutex mtx_;
    std::condition_variable cv_;
    bool ready_ = false;
    std::optional<int> value_;
    std::exception_ptr ex_;

    void set_value(int v) {
        std::lock_guard lk(mtx_);
        value_ = v;
        ready_ = true;
        cv_.notify_all();
    }

    int get() {
        std::unique_lock lk(mtx_);
        cv_.wait(lk, [&] { return ready_; });
        if (ex_) std::rethrow_exception(ex_);
        return value_.value();
    }
};
</int>