解决 Goroutines 死锁

在这种情况下，您在 Go 并发代码中遇到了死锁错误。让我们深入研究这个问题并提供一个有效的解决方案。

该错误是由于生产者和消费者的行为不匹配而发生的。在生产者函数中实现的生产者在有限的时间内在通道 ch 上发送值。然而，存在于主函数中的消费者无限期地运行，无休止地尝试从 ch.

接收值。要解决此死锁，您需要确保消费者尊重生产者的完成。这意味着当生产者完成发送值时，消费者应该自动终止。

一种有效的方法是利用sync.WaitGroup来协调生产者。等待组允许您跟踪生产者的进度并等待他们在关闭通道之前完成任务。这是代码的改进版本：

func main() {
    var wg sync.WaitGroup
    ch := make(chan int)

    wg.Add(1)
    go producer(ch, 100*time.Millisecond, 2, &wg)

    wg.Add(1)
    go producer(ch, 200*time.Millisecond, 5, &wg)

    // Start a goroutine to close the channel when all producers are done
    go func() {
        wg.Wait()
        close(ch)
    }()

    // Use a for range loop to receive values from the channel
    for v := range ch {
        fmt.Println(v)
    }
}

在此更新的代码中，sync.WaitGroup 用于跟踪活动生产者的数量。当生产者完成发送值时，调用 wg.Done() 来减少等待组。主 goroutine 使用 wg.Wait() 等待所有生产者完成，然后关闭 ch 通道。

通过使用sync.WaitGroup，您建立了一个协调机制，允许您的消费者尊重完成状态生产者的参与，有效解决死锁错误。