解決 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,您建立了一個協調機制,讓您的消費者尊重完成狀態生產者的參與,有效解決死鎖錯誤。
免責聲明: 提供的所有資源部分來自互聯網,如果有侵犯您的版權或其他權益,請說明詳細緣由並提供版權或權益證明然後發到郵箱:[email protected] 我們會在第一時間內為您處理。
Copyright© 2022 湘ICP备2022001581号-3