首頁 > 後端開發 > Golang > 主體

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

WBOY
發布: 2024-02-10 21:40:25
轉載
977 人瀏覽過

为什么我会收到 - 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
最新問題
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!