如何使用Go实现并发_Go goroutine使用方式说明

goroutine 启动后不执行的主因是 main 函数提前退出;应使用 sync.WaitGroup(Add/Done/Wait 配对)、channel 或 time.Sleep 等方式确保 main 等待 goroutine 完成。

goroutine 启动后不执行?检查是否主 goroutine 提前退出

Go 程序中 main 函数返回即整个程序退出,不会等待其他 goroutine 完成。这是最常见“goroutine 没运行”的原因。

典型错误写法:

func main() {
    go func() {
        fmt.Println("hello from goroutine")
    }()
    // main 直接结束,上面的 goroutine 很可能没来得及打印
}

正确做法是让 main 适当等待,常用方式有:

  • time.Sleep()(仅用于测试,不推荐生产)
  • sync.WaitGroup 等待所有任务完成
  • channel 配合 select 阻塞

sync.WaitGroup 是什么?怎么配对使用 Add/Done/Wait

sync.WaitGroup 是控制 goroutine 生命周期的核心工具,但必须严格配对:Add()Done() 数量一致,且 Wait() 必须在所有 Done() 之后才可能返回。

常见错误:

  • Add() 在 goroutine 内部调用(应在线程安全位置,如 main 中)
  • 忘记调用 Done(),导致 Wait() 永久阻塞
  • Wait() 被多次调用(它不是重入安全的)

正确示例:

func main() {
    var w

g sync.WaitGroup for i := 0; i < 3; i++ { wg.Add(1) // 必须在 go 前调用 go func(id int) { defer wg.Done() // 确保执行 fmt.Printf("task %d done\n", id) }(i) } wg.Wait() // 阻塞直到所有 Done() }

goroutine 泄漏:闭包变量捕获引发的意外共享

for 循环中直接使用循环变量启动 goroutine,容易因变量复用导致所有 goroutine 看到同一个值。

错误写法:

for i := 0; i < 3; i++ {
    go func() {
        fmt.Println(i) // 全部输出 3(循环结束后 i 的最终值)
    }()
}

修复方式(任选其一):

  • 将变量作为参数传入匿名函数:go func(val int) { ... }(i)
  • 在循环内定义新变量:val := i; go func() { fmt.Println(val) }()
  • 使用 Go 1.22+ 的 loopvar 实验性特性(需开启 GOEXPERIMENT=loopvar

什么时候该用 channel 而不是 WaitGroup?关注数据流动而非仅同步

WaitGroup 只解决“等完成”,而 channel 解决“等结果”或“协调通信”。如果需要收集返回值、限流、取消、超时,channel 更合适。

例如:并发请求多个 API 并聚合响应:

results := make(chan string, 3)
for _, url := range urls {
    go func(u string) {
        res, _ := http.Get(u)
        results <- res.Status
    }(url)
}
for i := 0; i < len(urls); i++ {
    fmt.Println(<-results) // 主动接收,天然带同步语义
}

注意:channel 容量要设好,否则发送方可能阻塞;读取次数必须匹配发送次数,否则会死锁。

goroutine 的本质是轻量级线程,但它的生命周期管理、变量作用域、通信机制都和传统线程不同——错一处,轻则逻辑错乱,重则死锁或泄漏。实际编码时,先想清楚:我要的是「等结束」还是「拿结果」,再决定用 WaitGroup 还是 channel,别凭直觉硬套。