英文:
Why do I get - go routines are asleep error for producer consumer issue
问题
这是代码 - 一个生产者在go协程中，多个消费者。
生产者正在向通道中传递信息，多个消费者（每个通过一个go协程）应该并行读取它。
func main() {alphabetArray := []string{"A", "B", "C"}alphabetChannel := make(chan string, 3)// 生产者go func() {for _, alphabet := range alphabetArray {alphabetChannel <- alphabet}}()var wg sync.WaitGroup// 生成10个消费者，每个消费者都表示为一个go协程。for idx := 0; idx < 10; idx++ {wg.Add(1)go func() {for alphabet := range alphabetChannel {fmt.Println(alphabet)}}()}wg.Wait()}
这是go playground的链接 - https://go.dev/play/p/yNdATAEexPB
我得到的错误是：
A
B
C
fatal error: all goroutines are asleep - deadlock!
英文:
Here is the code - a producer in go routine and multiple consumers.
The producer is pumping a channel with information and multiple consumers ( each via a go-routine ) should be reading it in parallel.
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()}
Here is the link to go playground - https://go.dev/play/p/yNdATAEexPB
The error I am getting is this -
A
B
C
fatal error: all goroutines are asleep - deadlock!
答案1
得分: 3
在生产者完成后关闭通道，这样消费者就会知道何时停止：
go func() {defer close(alphabetChannel)for _, alphabet := range alphabetArray {alphabetChannel <- alphabet}}()
让等待组知道消费者何时完成：
go func() {defer wg.Done()for alphabet := range alphabetChannel {fmt.Println(alphabet)}}()
英文:
Close the channel after producer is done, so the consumer would know when to stop:
go func() {defer close(alphabetChannel)for _, alphabet := range alphabetArray {alphabetChannel <- alphabet}}()
Let the waitgroup know when consumers are done:
go func() {defer wg.Done()for alphabet := range alphabetChannel {fmt.Println(alphabet)}}()
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论