task模板类支持链式异步任务流水线,通过operator>>=注册回调并自动传递前序结果,结合std::packaged_task或条件变量实现等待、取消与错误传播。

你需要让多个异步任务像流水线一样严格按顺序执行,前一个任务的返回值自动传给下一个任务,且整个链条支持等待、取消和错误传播——C++标准库的std::future和std::promise本身不提供链式组合能力,必须手动封装调度逻辑。
设计可链式拼接的任务包装器
定义Task模板类,它内部持有一个std::function<:any>执行体和一个std::shared_ptr<:promise>>结果承诺对象。
构造Task时,若传入可调用对象f,则立即用std::thread或线程池异步执行f→捕获异常→调用promise.set_value()或promise.set_exception();若不传f,则为占位空任务,用于衔接。
重载operator>>=(绑定操作符),接收一个函数g:std::any→Task,返回新Task;该操作不立即执行,只把g注册为当前Task完成后的回调,并将新Task的promise与当前Task的future关联起来。
这一步是链式模型的核心:operator>>=必须返回Task而非void,否则无法连续写task1 >>= f >>= g >>= h;【返回Task才能支持连续绑定,返回void会中断链式语法】。
实现future感知的链式调度器
方法一:基于std::future::wait_for轮询检测
在Task::then()中,创建新promise→启动一个独立线程监听原future.wait_for(1ms)→一旦ready,取出结果并调用绑定函数g→将g的返回值(可能是Task)的内部future再挂起监听。
方法二:使用std::thread + 条件变量主动通知(推荐)
每个Task内部维护std::condition_variable cv和bool ready标志;当原始任务执行完,先设置promise值,再notify_one()→监听线程被唤醒后立刻取值并触发后续任务。
注意:不能直接在原始执行线程里调用g,否则阻塞主线程;必须确保g总在独立上下文中运行。
用std::packaged_task构建无栈协程式任务链
第一步:声明packaged_task
第二步:定义lambda链式处理器,捕获上一级future和下一级packaged_task;用std::thread执行该lambda→其中调用prev_future.wait()→prev_future.get()→用结果构造新参数→调用next_task(arg)。
第三步:将第二步的lambda再次包装为packaged_task→递归生成下一级future→如此形成“future等待→取值→触发下一task”的闭环。
这种方法完全避开手动管理promise生命周期,所有资源由std::packaged_task自动管理,【但必须保证每级lambda捕获的future在其执行前不被销毁,否则get()会抛std::future_error】。
实战:HTTP请求→JSON解析→数据库写入三段链
auto req_task = Task<:string>([](){ return http_get("https://api.example.com/data"); });
auto parse_task = req_task >>= [](std::any res) { return Task<:json>([res](){ return nlohmann::json::parse(std::any_cast<:string>(res)); }); };
auto db_task = parse_task >>= [](std::any j) { return Task
db_task.get(); // 阻塞等待整条链完成,任一环节抛异常都会在此处rethrow
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











