多个goroutine并发读写共享变量未同步会引发数据竞争,导致程序行为不可预测,应使用互斥锁或原子操作确保同步访问。

Go语言以简洁高效的并发模型著称,goroutine和channel是其核心。但即便语法简单,开发者在实际使用中仍容易陷入一些常见陷阱。理解这些错误并掌握规避方法,对编写稳定、可维护的并发程序至关重要。
1. 忘记同步访问共享变量
多个goroutine同时读写同一变量而未加同步,会导致数据竞争(data race),程序行为不可预测。
例如:
func main() { var count int for i := 0; i上述代码输出结果不确定,因为
count++不是原子操作。
立即学习“go语言免费学习笔记(深入)”;
规避方法:
- 使用
sync.Mutex
保护临界区 - 改用
atomic
包进行原子操作 - 通过channel传递数据而非共享内存
推荐使用原子操作示例:
var count int64 atomic.AddInt64(&count, 1)2. goroutine泄漏
goroutine启动后未正常退出,导致内存和资源持续占用,最终引发OOM。
常见场景包括:
- 向无缓冲channel发送数据,但无人接收
- goroutine等待channel读取,但channel永不关闭
- 无限循环未设置退出条件
例如:
ch := make(chan int) go func() { val :=规避方法:
- 使用context控制goroutine生命周期
- 确保channel有发送/接收配对,或及时关闭
- 使用errgroup、worker pool等模式管理并发任务
使用context示例:
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second) defer cancel() go worker(ctx)3. 关闭已关闭的channel
Go语言中关闭已关闭的channel会引发panic,而向已关闭的channel发送数据也会panic,但接收是安全的。
例如:
ch := make(chan int) close(ch) close(ch) // panic: close of closed channel规避方法:
- 确保channel只由唯一的一方关闭
- 使用
sync.Once
保证关闭操作只执行一次 - 避免在多个goroutine中竞争关闭channel
安全关闭示例:
var once sync.Once once.Do(func() { close(ch) })4. range遍历未关闭的channel导致阻塞
使用
for range遍历channel时,如果channel未关闭,循环永远不会结束,goroutine会一直阻塞等待新数据。
例如:
ch := make(chan int) go func() { for v := range ch { fmt.Println(v) } }() // 忘记close(ch),range不会退出规避方法:
- 明确知道数据发送完成时,及时关闭channel
- 使用context或标志位控制循环退出
- 避免在不知道生产者是否结束的情况下使用range
正确做法:
close(ch) // 生产者发送完成后关闭基本上就这些。Go的并发模型虽简洁,但共享状态、生命周期管理和channel使用规则仍需谨慎对待。理解这些常见错误并养成良好的编程习惯,能有效提升程序的健壮性。











