go-concurrency-patterns

Go 并发模式

用于生产的 Go 并发模式，包括 goroutine、channel、同步原语和上下文管理。

何时使用本技能

• 构建 Go 并发应用
• 实现 worker 和流水线
• 管理 goroutine 生命周期
• 使用 channel 进行通信
• 调试竞态条件
• 实现优雅关闭

核心概念

1. Go 并发原语

原语	说明
goroutine	轻量级并发执行
channel	goroutine 之间的通信
select	多路复用 channel 操作
sync.Mutex	互斥
sync.WaitGroup	等待 goroutine 完成
context.Context	取消和截止时间

2. Go 并发箴言

Don't communicate by sharing memory;
share memory by communicating.

快速开始

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    results := make(chan string, 10)
    var wg sync.WaitGroup

    // Spawn workers
    for i := 0; i < 3; i++ {
        wg.Add(1)
        go worker(ctx, i, results, &wg)
    }

    // Close results when done
    go func() {
        wg.Wait()
        close(results)
    }()

    // Collect results
    for result := range results {
        fmt.Println(result)
    }
}

func worker(ctx context.Context, id int, results chan<- string, wg *sync.WaitGroup) {
    defer wg.Done()

    select {
    case <-ctx.Done():
        return
    case results <- fmt.Sprintf("Worker %d done", id):
    }
}

详细模式与完整示例

详细模式文档位于 references/details.md。当上述导航层级不够用时，请阅读该文件。

最佳实践

应该做的

• 使用 context —— 用于取消和截止时间
• 关闭 channel —— 只从发送方关闭
• 使用 errgroup —— 用于带错误的并发操作
• 为 channel 设置缓冲 —— 当你知道数量时
• 优先使用 channel —— 尽可能代替互斥锁

不应该做的

• 不要泄漏 goroutine —— 始终要有退出路径
• 不要从接收方关闭 —— 会导致 panic
• 不要使用共享内存 —— 除非必要
• 不要忽略 context 取消 —— 检查 ctx.Done()
• 不要用 time.Sleep 做同步 —— 使用合适的原语