扇入与扇出模式
合并多个通道并分配工作
扇入与扇出模式 是 CoddyKit 上的免费 Go Academy 课时。 这是第 3 节课，共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Go Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Go Academy 课程共包含 4 节课。
什么是扇出
扇出会将一个通道中的工作分配给多个协程，从而实现并行处理。每个工作协程都从同一个输入通道接收数据。
扇出示例
启动 N 个工作协程，让它们都从共享的任务通道读取数据：
func fanOut(jobs <-chan Job, n int) {
for i := 0; i < n; i++ {
go func() {
for job := range jobs {
process(job)
}
}()
}
}什么是扇入
扇入会将多个通道合并为一个通道，使单个消费者能够读取多个生产者产生的结果。
使用协程实现扇入
为每个输入通道启动一个协程；每个协程都将值转发到共享的输出通道。
func fanIn(cs ...<-chan int) <-chan int {
out := make(chan int)
var wg sync.WaitGroup
for _, c := range cs {
wg.Add(1)
go func(ch <-chan int) {
defer wg.Done()
for v := range ch { out <- v }
}(c)
}
go func() { wg.Wait(); close(out) }()
return out
}使用 select 实现扇入
对于数量固定的输入通道，使用 select 循环比为每个通道启动一个协程更简单。
func merge(a, b <-chan int) <-chan int {
out := make(chan int)
go func() {
defer close(out)
for a != nil || b != nil {
select {
case v, ok := <-a: if !ok { a = nil } else { out <- v }
case v, ok := <-b: if !ok { b = nil } else { out <- v }
}
}
}()
return out
}流水线阶段
将扇出和扇入结合起来即可构建流水线阶段：一个输入通道、N 个并行工作协程，以及一个合并后的输出通道。
func parallelStage(in <-chan Work, n int) <-chan Result {
outs := make([]<-chan Result, n)
for i := 0; i < n; i++ {
outs[i] = worker(in)
}
return fanIn(outs...)
}干净地关闭通道
由发送方关闭通道；接收方可以通过双值接收形式或遍历通道来检测关闭。绝不要由接收方关闭通道。
for v := range in { // exits when in is closed
process(v)
}使用 WaitGroup 进行协调
使用 sync.WaitGroup 确定所有扇出工作协程都已完成，然后关闭输出通道，使下游消费者能够结束。
背压
在流水线阶段之间使用带缓冲的通道来吸收突发流量。请根据生产者与消费者之间预期的延迟差异设置缓冲区大小。
out := make(chan Result, 100) // buffer absorbs bursts错误传递
将结果封装在同时携带值和错误的结构体中，使错误能够与数据一起流经流水线，而不会触发 panic。
type Result struct {
Value int
Err error
}上下文取消
在各个流水线阶段之间传递上下文，并在每个阶段检查 ctx.Done()，这样整个流水线就会在取消时停止。
case <-ctx.Done():
return ctx.Err()快速检查
在扇入模式中，谁负责关闭合并后的输出通道？
回顾：扇入与扇出
要点：
- 扇出：多个工作协程从一个通道读取数据
- 扇入：每个来源对应一个协程，多个来源合并到一个输出通道
- WaitGroup 负责协调合并通道的关闭
- 使用上下文执行取消；使用带缓冲的通道实现背压
常见问题解答
「扇入与扇出模式」课时是免费的吗？
是的 — 「扇入与扇出模式」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Go Academy 课程的其余内容，请升级到 CoddyKit PRO。 Go Academy 课程共包含 4 节课。
「扇入与扇出模式」这节课中我会学到什么？
合并多个通道并分配工作 你通过在浏览器中直接运行的动手代码来练习 Go Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Go Academy 需要有经验吗？
无需任何先前经验。CoddyKit 上的 Go Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。 这是第 3 节课，共 4 节。
「扇入与扇出模式」课时需要多长时间？
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。
我能在这节 Go Academy 课中编写并运行代码吗？
能。每节 Go Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。