Go语言通过goroutine实现轻量级并发,启动成本低(初始栈仅2KB),用go关键字启动,配合sync.WaitGroup协调多个goroutine的执行与等待,避免泄漏和竞态。

Go语言通过goroutine实现轻量级并发,无需手动管理线程生命周期,启动成本极低(初始栈仅2KB),适合高并发多任务场景。关键在于合理启动、协调与终止goroutine,避免泄漏和竞态。
启动goroutine执行独立任务
使用go关键字前缀函数调用即可启动goroutine。它会立即返回,不阻塞主流程:
- 普通函数:go doWork()
- 匿名函数:go func() { fmt.Println("task done") }()
- 带参数传递:go processItem(item)(注意传值而非引用,避免闭包变量复用问题)
等待多个goroutine完成:sync.WaitGroup
当需确保所有子任务执行完毕再继续,用sync.WaitGroup计数协调:
- 调用wg.Add(n)预设任务数
- 每个goroutine结束前调用wg.Done()
- 主goroutine调用wg.Wait()阻塞等待全部完成
示例:启动5个任务并统一等待
立即学习“go语言免费学习笔记(深入)”;
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func(id int) {
defer wg.Done()
fmt.Printf("Task %d finished\n", id)
}(i)
}
wg.Wait() // 主协程在此暂停,直到5个都调用Done
安全退出与资源清理:使用context.Context
长期运行的goroutine需支持主动取消。用context.WithCancel生成可取消上下文:
- 主goroutine调用cancel()通知所有监听该context的goroutine退出
- 子goroutine通过select监听ctx.Done()通道判断是否中止
- 可在case 分支中执行清理操作(如关闭文件、释放连接)
避免常见陷阱
goroutine易出错点需特别注意:
- 循环变量捕获错误:for循环中直接go f(i)可能所有goroutine看到同一个i值 → 改为go f(i)传参或go func(val int){...}(i)
- 主goroutine提前退出:若不等待或不处理Done信号,程序可能在子任务完成前就结束 → 必须用WaitGroup或context控制生命周期
- 无缓冲channel阻塞:向无缓冲channel发送数据时,若无接收方将永久阻塞goroutine → 确保配对收发,或使用带缓冲channel/select超时










