golang 使用 waitGroup 仍然以死锁错误告终

Question

我正在尝试按照 Go Concurrency 书实现桥接模式

func bridge_impl() {

    done := make(chan interface{})

    defer close(done)

    var wg sync.WaitGroup

    bridge := func(

        done <-chan interface{},

        chanStream <-chan <-chan interface{},

    ) <-chan interface{} {

        valStream := make(chan interface{})

        go func() {

            wg.Add(1)

            defer close(valStream)

            for {

                var stream <-chan interface{}

                select {

                case maybeStream, ok := <-chanStream:

                    fmt.Println("works")

                    if ok == false {

                        return

                    }

                    stream = maybeStream

                case <-done:

                    return

                }

                for val := range stream {

                    select {

                    case valStream <- val:

                    case <-done:

                    }

                }

            }

        }()

        return valStream

    }

    genVals := func() <-chan <-chan interface{} {

        chanStream := make(chan (<-chan interface{}))

        go func() {

            wg.Add(1)

            defer close(chanStream)

            for i := 0; i < 10; i++ {

                stream := make(chan interface{})

                stream <- i

                close(stream)

                chanStream <- stream

            }

        }()

        return chanStream

    }

    for v := range bridge(done, genVals()) {

        fmt.Printf("%v ", v)

    }

    wg.Wait()

}

但是我一开始收到一个死锁错误all goroutines are asleep - deadlock!，我想我应该添加一个等待组，即使它没有在书中的例子中实现，但我最终还是遇到了同样的错误

Answer 1

据我了解，您根本不需要 WaitGroup，您只需要重新排序genVals函数循环中的语句：for i := 0; i < 10; i++ {&nbsp; &nbsp; stream := make(chan interface{})&nbsp; &nbsp; chanStream <- stream&nbsp; &nbsp; stream <- i&nbsp; &nbsp; close(stream)}https://go.dev/play/p/7D9OzrsvZyi

Answer 2

有两个主要问题。工作示例第一期：for i := 0; i < 10; i++ {&nbsp; &nbsp; stream := make(chan interface{})&nbsp; &nbsp; stream <- i&nbsp; &nbsp; close(stream)&nbsp; &nbsp; chanStream <- stream}创建后写入无缓冲通道，没有 goroutine 读取。使用缓冲通道或其他 goroutine。stream := make(chan interface{}, 1) // buffer size 1 to not block `stream <- i`第二期：不使用。 您可以在这两种情况下使用。wg.Add(1)wg.Done()deferwg.Add(1)defer wg.Done()