<p>Go中channel作为函数参数必须显式指定方向：生产者用chan<- T，消费者用<-chan T，中间管道需分离in和out参数；应通过goroutine启动生产者避免阻塞；消费者须用val, ok := <-ch或for range检测关闭；多阶段管道应各用独立channel，禁止复用。</p>
channel 作为函数参数时，必须显式指定方向
Go 的 channel 类型支持方向限定：chan<- int（只写）、<-chan int（只读）、chan int（双向）。如果函数参数声明为 chan int，调用方传入的 channel 就无法被编译器约束读写行为，容易在消费者里意外写入、或在生产者里尝试读取，导致 panic 或逻辑错乱。
实际写法应按角色严格区分：
- 生产者函数参数用
chan<- string—— 只能 send - 消费者函数参数用
<-chan string—— 只能 receive - 中间管道函数（如过滤、转换）通常同时需要读和写，但应分别声明两个参数：
in <-chan int,out chan<- int
方向错误的典型报错是：invalid operation: cannot send to receive-only channel 或 cannot receive from send-only channel。
用匿名 goroutine 启动生产者，避免阻塞调用方
如果生产者函数直接向 channel 写入（比如遍历 slice 后逐个 send），且 channel 未缓冲或消费者还没启动，send 会永久阻塞，导致整个函数卡死。正确做法是在函数内启动 goroutine 执行写操作，让函数本身立即返回。
立即学习“go语言免费学习笔记（深入）”；
示例：
func produce(nums []int, out chan<- int) {
go func() {
defer close(out)
for _, n := range nums {
out <- n
}
}()
}注意三点：
-
defer close(out)必须在 goroutine 内，不能放在函数顶层（否则可能在写入前就关闭） - 不要在函数内直接
for写入 —— 这会让调用方等待全部数据发完 - 如果
out是带缓冲的 channel（如make(chan int, 10)），仍建议用 goroutine，因为缓冲只是延迟阻塞，不解决并发模型本质
消费者要处理 channel 关闭信号，避免无限循环
从 <-chan 读取时，仅用 val := <-ch 会阻塞直到有数据；而 val, ok := <-ch 才能感知 channel 是否已关闭。很多初学者漏掉 ok 判断，导致消费者在 channel 关闭后仍空转或 panic。
标准消费模式是：
for val := range ch {
// 处理 val
}但这个语法只适用于你「完全控制消费生命周期」的场景。如果消费者还需响应外部信号（如 context cancel）、或需在关闭后做清理，就必须手动用 for + select + ok：
-
range本质是自动展开为for { val, ok := <-ch; if !ok { break }; ... } - 混用
context.WithCancel时，必须用select等待ctx.Done()或 channel 数据 - 若消费者本身是管道一环（比如把 A channel 转发到 B channel），记得在退出前关闭
out
多个 stage 串联时，别复用同一个 channel 变量
常见错误是把一个 chan int 变量反复传给多个阶段函数，比如：
c := make(chan int) stage1(c) stage2(c) // ❌ 错误：stage1 可能已关闭 c，或仍在写入，stage2 读取行为不可控
正确方式是每个 stage 返回新 channel：
in := generateData() filtered := filter(in) processed := transform(filtered) consume(processed)
这样每段逻辑独立，生命周期清晰。关键点：
- 每个函数只负责自己的输入输出 channel，不关心上游是否关闭、下游是否 ready
- 如果某个 stage 需要扇出（fan-out），要用
for i := 0; i < n; i++ { go worker(in, out) }，而不是复制 channel 变量 - 扇入（fan-in）推荐用
sync.WaitGroup+ 多个go func()分别读取多个 in channel，统一写入一个 out
管道越长，变量复用越容易引发竞态或提前关闭 —— 每个 stage 的 channel 都该是“一次性的”。
