首頁 >後端開發 >Golang >為什麼我會收到 - goroutines are sleeped 錯誤,因為生產者消費者問題

為什麼我會收到 - goroutines are sleeped 錯誤,因為生產者消費者問題

WBOY
WBOY轉載
2024-02-10 21:40:251006瀏覽

为什么我会收到 - goroutines are sleeped 错误,因为生产者消费者问题

php小編柚子在解決程式設計問題時,可能會遇到一個常見的錯誤提示:「goroutines are sleeped」。這個錯誤通常與生產者消費者問題有關。生產者消費者問題是並發程式設計中的經典情景,其中一個或多個生產者產生數據,而一個或多個消費者從中取出數據進行處理。當生產者產生資料的速度超過消費者處理資料的速度時,就可能導致goroutines(Go語言中的輕量級執行緒)進入休眠狀態。本文將解釋為什麼會出現這個錯誤,並提供解決方法。

問題內容

這是程式碼 - go 例程中的生產者和多個消費者。 生產者正在向一個通道注入訊息,多個消費者(每個消費者透過一個 go-routine)應該並行讀取它。

func main() {
    alphabetArray := []string{"A", "B", "C"}

    alphabetChannel := make(chan string, 3)
    // producer.
    go func() {
        for _, alphabet := range alphabetArray {
            alphabetChannel <- alphabet
        }
    }()

    var wg sync.WaitGroup
    // spawn 10 consumers, consumers represented as a go-routine.
    for idx := 0; idx < 10; idx++ {
        wg.Add(1)
        go func() {
            for alphabet := range alphabetChannel {
                fmt.Println(alphabet)
            }
        }()
    }
    wg.Wait()
}

這是去遊樂場的連結 - https://go.dev/play/p/yndataeexpb

我收到的錯誤是這樣的 -

一個 乙 c 致命錯誤:所有 goroutine 都在睡覺 - 死鎖!

解決方法

生產者完成後關閉通道,以便消費者知道何時停止:

go func() {
        defer close(alphabetchannel)
        for _, alphabet := range alphabetarray {
            alphabetchannel <- alphabet
        }
    }()

讓等待群組知道消費者何時完成:

go func() {
            defer wg.Done()
            for alphabet := range alphabetChannel {
                fmt.Println(alphabet)
            }
        }()

以上是為什麼我會收到 - goroutines are sleeped 錯誤,因為生產者消費者問題的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文轉載於:stackoverflow.com。如有侵權,請聯絡admin@php.cn刪除