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

Golang不知道大家是否熟悉？今天我将给大家介绍《生产者消费者问题：为什么我会收到 - goroutines are sleeped 错误？》，这篇文章主要会讲到等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

这是代码 - 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 错误？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！