Go并发模式实战

Go语言的并发模型是其最核心的特性之一，通过goroutine和channel实现高效的并发编程。本文深入讲解goroutine、channel和select的实际使用场景。

Goroutine：轻量级并发

goroutine是Go实现的轻量级线程，由Go runtime管理。创建goroutine只需在函数调用前添加go关键字：

go func() {
    // 并发执行的代码
}()
​

使用场景：

• I/O密集型任务：网络请求、文件读写
• 并行处理：批量数据处理、图像渲染
• 后台任务：日志记录、监控采集

最佳实践：

• 控制并发数量：使用worker pool模式避免goroutine爆炸
• 传递context：实现优雅关闭和超时控制
• 避免共享状态：通过channel通信而非共享内存

Channel：通信机制

channel是goroutine之间的通信管道，遵循"CSP"（通信顺序进程）模型：

ch := make(chan int, 10) // 带缓冲的channel
ch <- value               // 发送
value := <-ch             // 接收
​

使用场景：

• 数据传递：生产者-消费者模式
• 结果收集：fan-in模式聚合多个goroutine结果
• 流水线处理：分阶段处理数据
• 信号通知：done channel控制goroutine生命周期

缓冲vs无缓冲：

• 无缓冲：同步通信，发送方阻塞直到接收方ready
• 缓冲：异步通信，容量内发送方不阻塞，适合生产消费速率不匹配场景

Select：多路复用

select可同时监听多个channel操作，实现超时、取消等复杂控制：

select {
case <-timeout:
    return errors.New("timeout")
case result := <-ch:
    return result
}
​

核心模式：

• 超时控制：time.After channel
• 非阻塞操作：default分支
• 多源处理：响应最先到达的channel
• 退出监听：done channel实现优雅退出

实战模式

Worker Pool模式

func workerPool(tasks <-chan Task, results chan<- Result) {
    for i := 0; i < 5; i++ {
        go func() {
            for task := range tasks {
                results <- process(task)
            }
        }()
    }
}
​

Pipeline模式

func generator(nums ...int) <-chan int {
    out := make(chan int)
    go func() {
        for _, n := range nums {
            out <- n
        }
        close(out)
    }()
    return out
}
​

Fan-Out/Fan-In

• Fan-Out：多个goroutine从同一channel读取，并行处理
• Fan-In：多个goroutine结果写入同一channel，聚合并行结果

注意事项

1. 避免goroutine泄漏：确保所有goroutine能正确退出，使用context或done channel
2. channel关闭原则：发送方负责关闭channel，接收方不关闭
3. nil channel阻塞：向nil channel发送/接收会永久阻塞
4. select随机性：多个case就绪时随机选择，避免依赖执行顺序

Go的并发哲学是"通过通信来共享内存"，而非"通过共享内存来通信"。掌握goroutine、channel和select，能构建高效、优雅的并发系统。