co_yield本身不支持管道,需通过自定义generator类及其promise_type::yield_value等机制手动实现拉取驱动的流式组合。

co_yield 本身不支持管道,得靠协程返回类型手动实现
标准 C++20 的 co_yield 只是把值“抛给”协程的 promise 对象,它不提供链式消费、组合或类似 Python 的 yield from 行为。所谓“生成器管道”,本质是让一个生成器的输出直接作为另一个生成器的输入源——这必须由你定义的协程返回类型(比如 generator<t></t>)来承载调度逻辑,而非 co_yield 自动完成。
常见错误是以为写个 co_yield f(); co_yield g(); 就算管道了——这只是顺序产出,没有数据流控制、暂停/恢复交接、或跨协程的值转发能力。
- 真正管道需要两个生成器之间建立“拉取驱动”关系:下游调用
next()时,上游才执行到下一个co_yield - 必须用自定义的
generator类封装协程句柄(std::coroutine_handle<promise_type></promise_type>),并重载begin()/end()支持范围 for - 管道操作符(如
|)通常通过自由函数 + ADL 实现,返回嵌套的 generator(例如generator<int> operator|(generator<int> src, std::function<int> fn)</int></int></int>)
用 generator 实现基础管道需重载 promise_type::yield_value
标准库没提供 generator,得自己写或用第三方(如 cppcoro、range-v3)。以简化版为例:关键不是 co_yield x 这行代码,而是它的底层调用目标——promise_type::yield_value(x) 是否能保存值、挂起,并允许外部通过 iterator 拉取。
如果你漏掉 promise_type::get_return_object() 返回正确的 generator 实例,或者没实现 iterator::operator++() 去调用 resume(),那根本跑不起来,更别说管道。
-
yield_value必须把值存进 promise 对象的成员(如current_value),并返回std::suspend_always{}让协程挂起 -
iterator的operator*应返回promise.current_value,operator++调用handle.resume() - 管道中每个中间步骤(如过滤、映射)都应返回新
generator,其promise_type内部持有上游generator::iterator,并在resume()时主动从上游拉一个值
管道组合容易踩的坑:生命周期与悬挂协程
最常崩溃的场景是管道里某层 generator 析构了,但下游还在尝试 ++it——这时 handle 已无效,resume() 触发未定义行为。C++ 协程没有自动引用计数,所有 handle 管理全靠你。
组合式C++代码评审方案,融合静态分析、AI推理、多轮迭代评审和C++专项检查,适用于PR审查、增量代码审查、全项目评审和代码质量评分,触发词包括review cpp、cpp代码评审、C++review、代码审查。
另一个隐形问题是“惰性求值”被意外打破:比如在管道构造阶段就提前执行了全部 co_yield(因为用了 vector 缓存结果),那就失去了管道的流式特性,内存爆涨且无法短路终止。
- 避免在 promise 中用 raw pointer 持有上游 iterator;改用
std::shared_ptr或确保上游 lifetime 长于下游(如用 scope guard 或显式传入 const ref) - 不要在
generator构造函数里遍历上游;真正的拉取必须延迟到iterator::operator++()中 - 调试时加断点看
handle.done()返回 true 的时机——如果过早,说明上游已结束但下游没收到通知,可能漏了final_suspend的处理
一个可运行的 map 管道示例(仅核心骨架)
下面这个 map 函数把 generator<int></int> 映射为 generator<:string></:string>,它就是最简管道单元:
template<typename src typename func>
auto map(generator<src> src, Func f) {
return [&]() -> generator<:invoke_result_t src>> {
for (auto&& v : src) { // 每次这里才从 src 拉一个值
co_yield f(v); // 转换后 yield 给外层
}
}();
}
</:invoke_result_t></src></typename>
使用时:for (auto s : map(my_ints(), [](int x) { return std::to_string(x * 2); })) { ... }。注意两点:1)map 返回的是立即调用的 lambda,保证协程按需启动;2)for (auto&& v : src) 依赖 src 的 begin()/end() 正确实现——否则就是静默失败。
真实项目里,这种手写易错,建议优先用 cppcoro 的 task/generator 或 range-v3 的 async view;但只要涉及自定义调度、错误注入或状态保持,还是得回到 promise_type 层抠细节。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!










