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

10次阅读

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

如何使用Go实现并发_Go 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 wg sync.WaitGroup     for i := 0; i < 3; i++ {         wg.Add(1) // 必须在 go 前调用         go func(id int) {             defer wg.Done() // 确保执行             fmt.Printf("task %d donen", 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,别凭直觉硬套。

text=ZqhQzanResources