Go开发疑难杂症终结者通关指南|果fx

在 Go 语言中，并发编程是其核心特性之一，但也可能导致一些棘手的问题。以下是一些常见的并发问题及其解决方案：

1. 数据竞争 (Data Races)

问题描述：多个 goroutine 同时读写同一变量，导致数据不一致。

解决方案：

• 使用 sync.Mutex 或 sync.RWMutex 来保护共享资源。
• 使用 channel 来传递数据，避免直接访问共享变量。

var mu sync.Mutex
var sharedData int

func safeIncrement() {
    mu.Lock()
    sharedData++
    mu.Unlock()
}

2. 死锁 (Deadlock)

问题描述：两个或多个 goroutine 因互相等待对方释放锁而导致程序停止。

解决方案：

• 确保获取锁的顺序一致。
• 使用 sync.WaitGroup 来协调 goroutine 的完成，避免锁的复杂使用。

var mu1, mu2 sync.Mutex

func deadlockExample() {
    mu1.Lock()
    defer mu1.Unlock()

    mu2.Lock()
    defer mu2.Unlock()
}

3. 饥饿现象 (Starvation)

问题描述：某些 goroutine 永远无法获得执行机会，因其他 goroutine 始终占用资源。

解决方案：

• 调整调度策略，确保公平性。
• 避免长时间占用锁，尽量缩小临界区。

4. goroutine 泄漏 (Goroutine Leak)

问题描述：未能正确结束 goroutine，导致内存消耗逐渐增大。

解决方案：

• 确保所有启动的 goroutine 都有明确的退出条件。
• 使用 context.Context 来控制 goroutine 的生命周期。

ctx, cancel := context.WithCancel(context.Background())
defer cancel()

go func() {
    select {
    case <-ctx.Done():
        return
    }
}()

5. 通道阻塞 (Channel Blocking)

问题描述：发送到已满的通道或从空通道接收会导致 blocking。

解决方案：

• 使用 buffered channels 来允许一定数量的消息排队。
• 检查通道的状态，适当地使用 select 语句处理超时。

ch := make(chan struct{}, 10) // buffered channel

select {
case ch <- value:
    // 发送成功
default:
    // 处理通道满的情况
}

6. 不合理的 goroutine 数量

问题描述：创建过多的 goroutine 导致系统性能下降。

解决方案：

• 使用 worker pool 模式来限制同时运行的 goroutine 数量。

const numWorkers = 5

for i := 0; i < numWorkers; i++ {
    go worker(i, jobs, results)
}

7. 竞态条件 (Race Conditions)

问题描述：程序的输出依赖于 goroutine 执行的顺序，导致不确定性。

解决方案：

• 尽量减少共享状态的使用。
• 利用通道进行同步，确保相关操作在合适的时机执行。