Go 如何实现协程并发控制？

Question

Go 如何实现协程并发控制？

仓乃文 · Accepted Answer

Go 使用 goroutine 实现并发，通过 sync.WaitGroup 等待协程完成，channel 传递数据，context 控制超时和取消。

基础并发控制（WaitGroup）：
```go
package main

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

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()  // 协程结束时计数器减 1
    fmt.Printf("Worker %d 开始
", id)
    time.Sleep(time.Second)
    fmt.Printf("Worker %d 完成
", id)
}

func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 5; i++ {
        wg.Add(1)  // 计数器加 1
        go worker(i, &wg)
    }
    wg.Wait()  // 等待所有协程完成
    fmt.Println("所有 worker 完成")
}
```

限制并发数量（信号量模式）：
```go
func main() {
    const maxConcurrency = 3
    sem := make(chan struct{}, maxConcurrency)  // 带缓冲 channel 作为信号量
    var wg sync.WaitGroup

for i := 1; i <= 10; i++ {
        wg.Add(1)
        go func(id int) {
            defer wg.Done()
            sem <- struct{}{}        // 获取信号量
            defer func() { <-sem }() // 释放信号量
            fmt.Printf("处理任务 %d
", id)
            time.Sleep(time.Second)
        }(i)
    }
    wg.Wait()
}
```

补充说明：
- goroutine 是轻量级线程，栈初始只有 2KB，可以创建数十万个
- WaitGroup 不能复制，必须传指针
- 带缓冲 channel 可以实现信号量模式限制并发
- errgroup 包可以同时处理错误传播和并发控制