php小編柚子在解決編程問題時，可能會遇到一個常見的錯誤提示：“goroutines are sleeped”。這個錯誤通常與生產(chǎn)者消費者問題有關(guān)。生產(chǎn)者消費者問題是并發(fā)編程中的一種經(jīng)典情景，其中一個或多個生產(chǎn)者生成數(shù)據(jù)，而一個或多個消費者從中取出數(shù)據(jù)進行處理。當生產(chǎn)者生成數(shù)據(jù)的速度超過消費者處理數(shù)據(jù)的速度時，就可能導致goroutines（Go語言中的輕量級線程）進入休眠狀態(tài)。本文將解釋為什么會出現(xiàn)這個錯誤，并提供解決方法。
問題內(nèi)容
這是代碼 – go 例程中的生產(chǎn)者和多個消費者。
生產(chǎn)者正在向一個通道注入信息，多個消費者（每個消費者通過一個 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 都在睡覺 – 死鎖！
解決方法
生產(chǎn)者完成后關(guān)閉通道，以便消費者知道何時停止：
go func() {
defer close(alphabetchannel)
for _, alphabet := range alphabetarray {
alphabetchannel <- alphabet
}
}()
登錄后復制
讓等待組知道消費者何時完成：
go func() {
defer wg.Done()
for alphabet := range alphabetChannel {
fmt.Println(alphabet)
}
}()
登錄后復制
