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

因为std::future不支持.then()等延续操作，get()会阻塞、wait_for()需轮询，且c++11/14标准未提供continuation机制；强行手动调度易致悬挂引用或future_error；可行方案为自封装可移动task容器或依赖第三方库。

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

为什么不能直接用 std::future 做链式调用

因为 std::future（尤其是 std::promise 配套的）本身不支持 .then() 这类延续操作，调用 get() 会阻塞，而 wait_for() 又得轮询——这和“异步链式”目标根本冲突。C++11/14 标准库没提供 continuation 机制，强行用 std::thread + std::future 手动调度，容易出现悬挂引用、std::future 被多次 get() 导致 std::future_error: No state 错误。

真正可行的路径只有两条：自己封装带回调的任务容器，或依赖第三方（如 Boost.Thread 的 boost::future），但后者引入重量级依赖。实战中更推荐轻量自建——核心是把“任务执行完触发下一个”的逻辑收口到一个可移动、可组合的对象里。

如何设计可移动、可链式拼接的 task 包装器

关键不是模拟 JavaScript 的 Promise，而是围绕 std::function + std::shared_ptr 管理状态 + 移动语义做收敛。每个 task 对象应持有：std::shared_ptr<state></state>（存值/异常/就绪标记）、std::function<void></void>（实际工作函数）、以及一个 std::vector<:function>></:function>（后续回调队列）。

构造时只注册工作函数，不执行；调用 run() 或被前序 task 触发时才在线程池中执行
then() 不立即执行，只是把传入的 lambda 压入当前 task 的回调队列，并返回一个新的 task 实例（内部共享同一 state）
必须显式支持 std::move 构造和赋值，否则链式表达式（如 a.then(...).then(...)）中间临时对象会被析构，导致回调丢失
避免裸指针或 this 捕获：回调 lambda 内部若需访问外部变量，一律用值捕获或 std::shared_ptr 持有，否则易出现 use-after-free

线程池调度与 future 就绪通知怎么解耦

不要让 task 自己管理线程——它只负责定义“做什么”和“谁来接着做”，调度交给独立的 thread_pool。重点在于：当一个 task 执行完毕，必须以无锁方式通知其所有后续 task 就绪。这里用 std::atomic_bool + std::condition_variable 组合太重；更轻量的做法是，在 state 中用 std::atomic<int></int> 表示状态（0=未开始，1=运行中，2=完成，3=异常），然后在 then() 返回的新 task 的 run() 方法里，先 wait_until_ready()（自旋+yield，适用于短延迟），再取值或抛异常。

C++14

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

下载

示例片段（简化）：

struct task_state {
    std::atomic<int> status{0};
    std::exception_ptr except;
    std::optional<int> result; // 假设返回 int
};

void task::run() {
    if (state->status.exchange(1) == 0) { // CAS 成功才执行
        try {
            state->result = work(); // 执行实际逻辑
            state->status = 2;
        } catch (...) {
            state->except = std::current_exception();
            state->status = 3;
        }
        // 触发所有 then 回调（通过线程池 post）
        for (auto& cb : callbacks) pool.post(cb);
    }
}
</int></int>

std::future 与自建 task 如何安全桥接

很多场景需要把自建 task 转成标准 std::future（比如对接 legacy API）。不能直接把 task 的 state 绑定到 std::promise——因为 std::promise 的 set_value() / set_exception() 只能调用一次，而自建 task 可能被多个 then() 共享。正确做法是：在桥接时新建一个 std::promise，在其 set_* 方法里转发到目标 std::future，并确保只调用一次。

用 std::weak_ptr<task_state></task_state> 持有状态，避免循环引用（尤其当 then 回调又生成新 task 时）
桥接函数如 to_std_future() 应返回 std::future<t></t>，且内部 std::promise 生命周期由返回的 future 管理
如果原 task 已完成，桥接必须立刻 set_value() 或 set_exception()，否则 future.wait() 会永远挂起
别忘了处理 std::future<void></void> 特化：此时 state->result 可为 std::monostate 或直接省略