go里的管道式处理指函数组合链式调用，每个阶段接收chan t、输出chan u，核心是类型安全通道传递；io.pipe与此无关，它是用于goroutine间同步字节流的低层内存配对工具，无缓冲、需成对goroutine协作。
什么是 Go 里的管道式处理，和 io.Pipe 有关系吗？
没有直接关系。io.Pipe 是用于协程间同步字节流的低层工具，而“管道式数据流处理”指的是一种函数组合模式：把多个阶段（如过滤、映射、聚合）串成链式调用，每个阶段接收一个 chan T，输出另一个 chan U。核心是类型安全的通道传递，不是字节流转发。
关键在于：每个阶段必须显式关闭输出通道，否则下游 range 会永远阻塞；同时要避免 goroutine 泄漏——哪怕上游提前退出，当前阶段也得及时停止。
怎么写一个通用的过滤阶段函数？
用泛型定义，接收输入通道、过滤函数，返回新通道。注意三点：启动 goroutine 封装逻辑、手动关闭输出通道、检查输入是否已关闭。
func Filter[T any](in 是最简签名，但实际需支持取消和错误传播- 必须在 goroutine 内做
for range in，否则会阻塞调用方 - 不能直接在循环里
close(out)，要 defer 或用select配合done通道提前退出 - 示例片段：
func Filter[T any](in
为什么用 select + default 而不是直接写 out ？
因为下游可能已退出（比如只取前 5 个结果），此时 out 虽未关闭，但无 goroutine 接收，直接写会导致当前 goroutine 永久阻塞。
-
select+default实现非阻塞发送：发不出就立刻放弃，靠 defer 关闭通道保证下游能退出 - 更健壮的做法是加
done通道，用select { case out - 如果阶段需要返回错误（比如 IO 过滤器），就不能只用
chan T，得改成chan Result[T]或额外传入errCh chan
组合多个阶段时最容易漏掉什么？
每个阶段的 goroutine 生命周期管理。常见错误是：上游因错误提前关闭，但下游 stage 仍在等待输入，导致 goroutine 泄漏。
- 所有阶段都应接受一个
context.Context，并在select中监听ctx.Done() - 不要把多个 stage 写在同一个 goroutine 里（看似省事，实则失去并发性和可中断性）
- 测试时用
time.After模拟超时，观察 goroutine 数量是否回落 ——runtime.NumGoroutine()是快速验证手段 - 如果某阶段需缓冲（如批量过滤），别用
make(chan T, N)硬编码容量，而是通过参数传入，否则管道吞吐量会被卡死
真正难的不是写出第一个 Filter，而是让整条 pipeline 在任意阶段出错、取消、限速时，所有 goroutine 都能干净退出。这需要每个阶段都把 context 和 channel 关闭逻辑写实，而不是依赖“上游总会关”的假设。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
