扇入是将多个channel合并为一个，便于统一处理；扇出则是将一个channel分发给多个goroutine处理。1. 扇入实现方式是启动多个goroutine读取各自的channel，并发送至同一输出channel，需注意手动关闭输出channel并限制并发数；2. 扇出通过多个worker从同一channel消费数据，适用于高吞吐任务，建议控制worker数量并使用带缓冲channel；3. 实际应用中要注意channel关闭、错误统一处理、并发上限控制等问题，确保资源合理利用和程序稳定性。
在Go语言的并发编程中，扇入（Fan-In）和扇出（Fan-Out）是两个常见的模式。它们用于处理多个goroutine之间的数据流动，特别是在需要聚合多个channel输出或向多个goroutine分发任务时非常实用。
这篇文章就来聊聊怎么用好这两个模式，以及一些实际使用中的小技巧。
什么是扇入（Fan-In）？
扇入是指将多个channel的数据“合并”到一个channel中，便于统一处理。这在需要从多个来源收集结果的场景下很常见，比如并行计算后汇总结果、监听多个事件源等。
立即学习“go语言免费学习笔记（深入）”；
实现方式：
- 启动多个goroutine，每个都从自己的channel读取数据
- 所有goroutine都将结果发送到同一个输出channel
func fanIn(chs ...<-chan int) <-chan int {
out := make(chan int)
for _, ch := range chs {
go func(c <-chan int) {
for val := range c {
out <- val
}
}(ch)
}
return out
}注意点：
- 输出channel不会自动关闭，除非你手动控制所有输入channel都已关闭
- 如果输入channel数量较多，要考虑是否要限制并发goroutine数量，避免资源耗尽
什么是扇出（Fan-Out）？
扇出是指把一个channel的数据“分发”给多个goroutine去处理。这个模式适用于高吞吐量的任务分发，比如并发处理HTTP请求、批量数据处理等。
实现方式：
- 启动多个worker goroutine，都从同一个channel读取数据
- 数据被“轮流”消费，取决于调度器如何分配
func startWorkers(in <-chan int, num int) {
for i := 0; i < num; i++ {
go func() {
for val := range in {
fmt.Println("Worker received:", val)
}
}()
}
}适用场景：
- 需要并发处理大量独立任务
- 每个任务之间不需要共享状态
- 要求系统具备横向扩展能力，比如增加worker数提升吞吐
建议：
- 控制worker数量，不要无限制启动
- 使用带缓冲的channel可以提升性能，但也要注意内存占用
实际应用中的几个细节
-
channel关闭问题
- 在扇入模式中，如果有一个channel没关闭，整个输出channel就不会结束
- 可以使用sync.WaitGroup来等待所有输入channel完成后再关闭输出channel
-
错误处理要统一
- 多个goroutine可能都会出错，最好统一返回error channel进行集中处理
- 不要在每个worker里单独panic，应该通过channel通知主流程
-
合理使用带缓冲channel
- 带缓冲的channel可以缓解生产者与消费者之间的速度差异
- 但缓冲太大可能导致内存浪费，太小又会阻塞生产者
-
控制并发上限
- 扇出模式中，worker数量不宜过多，可以根据CPU核心数做调整
- 可以结合goroutine池来复用资源，避免频繁创建销毁
基本上就这些。扇入扇出虽然看起来简单，但在实际项目中容易踩坑的地方不少，尤其是channel的生命周期管理和并发控制。写代码的时候多想一步，后面调试起来就能省很多力气。
