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

C++中构建了支持链式拼接、自动调度、错误传递与取消的异步任务流：定义Task模板类（禁拷贝、只允许移动）、重载>>构建依赖、ThreadPoolScheduler绑定线程池与无锁队列、提供make_ready/delay/read_file等节点，start()触发自动执行。

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

你需要在C++中构建一个可链式拼接、自动调度、支持错误传递与取消的异步任务流，避免手写回调嵌套、规避std::future阻塞等待、确保每个节点能自然返回下一个任务而无需顶层显式循环驱动。

定义可链式调用的异步任务基类

新建Task.h头文件，声明模板类Task，它内部持有std::shared_ptr<:taskbase>，不直接暴露执行逻辑；构造函数禁用拷贝，只允许移动——因为任务对象一旦被move，原对象必须置为空状态，否则后续调用get()会触发未定义行为。

为Task重载operator>>，返回Task类型，该操作符不执行任何调度，仅打包前后两个任务的依赖关系到新Task对象中；注意此处不能用auto推导返回类型，必须显式写成Task，否则模板实例化失败。

这一步操作起来很简单，直接把文件拖进去就行。

实现底层任务调度器与线程池绑定

创建ThreadPoolScheduler类，继承自std::enable_shared_from_this，内部持有一个无锁队列和一个vector<:thread>；构造时启动固定数量线程，每个线程死循环调用queue.pop()→执行→continue。

关键点在于pop操作必须是原子的且支持超时等待，否则空队列时线程会陷入忙等；我们使用std::condition_variable配合std::mutex实现带超时的wait_for，超时后检查是否shutdown_为true，若是则退出循环。

在schedule方法中，将传入的std::function包裹进lambda，捕获this->weak_from_this()，防止调度器被提前析构；【若未使用weak_ptr捕获，任务执行期间调度器销毁会导致core dump】。

编写具体任务节点：从值、异常、延迟到IO就绪

方法一：立即完成任务——Task::make_ready(42)。内部调用new detail::ReadyTask(42)，该对象的run()直接调用set_value()并通知等待者。

C++14

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

下载

方法二：延迟执行任务——Task<:string>::delay(std::chrono::milliseconds(100)) → []{ return "done"; }。延迟由std::thread+std::this_thread::sleep_for实现，注意sleep前需检查cancel_token是否已触发，否则无法响应取消请求。

方法三：文件读取任务——Task<:vector>>::read_file("config.json")。使用POSIX aio_read或Windows OVERLAPPED，但跨平台统一走libuv封装层；【不要在主线程调用aio_suspend，它会阻塞】，必须交由专用IO线程处理完成事件。

组装链式流程并触发执行

第一步：声明起始任务，例如auto t1 = Task::make_ready(10);

第二步：链式追加计算节点，t1 >> [](int x) { return Task::make_ready(x * 3.14); } >> [](double y) { return Task<:string>::make_ready("pi: " + std::to_string(y)); };

第三步：调用最后任务的start()，传入shared_ptr；start()内部触发首个节点run()，后续节点由前一个节点的set_value()回调自动触发；若中间某步抛出异常，则异常会被捕获并转为Task::make_exception，下游节点仍可接收并处理error状态。

第四步：不需要手动等待，所有任务在后台线程中自动推进完成。