必须启动goroutine，因为channel发送会阻塞，函数返回后栈帧销毁；正确做法是在函数内用go启动匿名goroutine持续发送，再返回channel，否则range时会卡死或panic。
channel 作为返回值时，函数必须启动 goroutine
Go 中函数不能直接“返回一个正在发送数据的 channel”，因为 send 操作会阻塞，而函数返回后其栈帧就销毁了。所以常见写法是：函数内部用 go 启动匿名 goroutine，在其中持续 send，再把 chan 本身返回。否则调用方一 range 就卡死或 panic。
典型错误是忘记 go 关键字，比如：
func badStream() <-chan int {
ch := make(chan int)
ch <- 1 // 这里就阻塞，函数永远无法返回
return ch
}正确做法是：
- 用
make(chan T)创建无缓冲或有缓冲 channel - 在
go func() { ... }()中执行所有send操作 - 发送完毕后
close(ch)（可选，但推荐，方便接收方感知结束） - 返回只读 channel 类型
<-chan T，避免外部误写
如何安全地终止流式 channel 并避免 goroutine 泄漏
如果流式函数依赖外部条件（如超时、取消、数据源关闭），不加控制会导致 goroutine 永不退出，内存和 goroutine 数持续增长。最稳妥的方式是接收 context.Context 参数，并在 goroutine 内监听 ctx.Done()。
立即学习“go语言免费学习笔记（深入）”；
常见疏漏点：
- 只检查
ctx.Err() == context.Canceled，却没在select中监听ctx.Done()—— 导致取消信号无法及时捕获 - 在
for循环中直接send而不select，一旦接收方提前退出，goroutine 就卡在ch <- x - 忘记在
defer close(ch)前加判断，导致对已关闭 channel 再次 close panic
示例节选：
func streamWithCtx(ctx context.Context, nums []int) <-chan int {
ch := make(chan int)
go func() {
defer close(ch)
for _, n := range nums {
select {
case ch <- n:
case <-ctx.Done():
return
}
}
}()
return ch
}buffered channel 能缓解阻塞，但不解决背压本质问题
给 channel 加缓冲（如 make(chan int, 10)）能让发送方短时间“不阻塞”，但它只是把压力从 goroutine 切换到内存：如果接收方太慢，缓冲区填满后仍会阻塞；若持续发不停，可能 OOM。
所以缓冲只是权衡手段，不是背压解决方案。实际使用中需注意：
- 缓冲大小应与预期峰值流量匹配，而非盲目设大（如
10000） - 若上游是实时数据源（如日志行、HTTP 流），缓冲仅用于应对瞬时抖动，必须配合超时或取消机制
- 接收方用
range时，缓冲不影响语义，但若用<-ch单次读取，缓冲决定了是否立即返回
组合多个 channel 流时，select + nil channel 是关键技巧
实现类似 “merge” 或 “fan-in” 逻辑时（如合并两个数据流），不能简单 range 多个 channel —— Go 不支持多 channel range。标准做法是用 select 轮询，配合 nil channel 控制开关。
容易出错的是：未将已关闭的 channel 设为 nil，导致 select 仍尝试从中接收，立刻返回零值并继续循环，造成空转或重复发送零值。
正确模式：
func merge(a, b <-chan int) <-chan int {
ch := make(chan int)
go func() {
defer close(ch)
for a != nil || b != nil {
select {
case v, ok := <-a:
if !ok { a = nil } else { ch <- v }
case v, ok := <-b:
if !ok { b = nil } else { ch <- v }
}
}
}()
return ch
}这里 a = nil 后，对应 case 在 select 中自动失效，真正实现“动态轮询活跃流”。
实际写流式函数时，最常被忽略的是 context 取消后的资源清理和 channel 关闭时机 —— 它不像 HTTP handler 那样有明确生命周期钩子，全靠开发者手动保障。
