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