如何使用sync.WaitGroup防止Go並發死鎖？

解決 Goroutines 死鎖

在這種情況下，您在 Go 並發程式碼中遇到了死鎖錯誤。讓我們深入研究這個問題並提供一個有效的解決方案。

由於生產者和消費者的行為不符而發生錯誤。在生產者函數中實現的生產者在有限的時間內在通道 ch 上發送值。但是，主函數中存在的消費者會無限期地運行，無休止地嘗試從 ch.

接收值。要解決此死鎖，您需要確保消費者尊重生產者的完成。這意味著當生產者完成發送值時，消費者應該自動終止。

一個有效的方法是利用sync.WaitGroup來協調生產者。等待群組允許您追蹤生產者的進度並等待他們在關閉通道之前完成任務。這是程式碼的改進版本：

<code class="go">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)
    }
}</code>

在此更新的程式碼中，sync.WaitGroup 用於追蹤活動生產者的數量。當生產者完成發送值時，呼叫 wg.Done() 來減少等待群組。主 Goroutine 使用 wg.Wait() 等待所有生產者完成，然後關閉 ch 通道。

透過使用sync.WaitGroup，您建立了一個協調機制，讓您的消費者尊重完成狀態生產者的參與，有效解決死鎖錯誤。

以上是如何使用sync.WaitGroup防止Go並發死鎖？的詳細內容。更多資訊請關注PHP中文網其他相關文章！