我正在嘗試按照 Go Concurrency 書實(shí)現(xiàn)橋接模式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()}但是我一開始收到一個(gè)死鎖錯(cuò)誤all goroutines are asleep - deadlock!，我想我應(yīng)該添加一個(gè)等待組，即使它沒有在書中的例子中實(shí)現(xiàn)，但我最終還是遇到了同樣的錯(cuò)誤
2 回答
DIEA
TA貢獻(xiàn)1820條經(jīng)驗(yàn) 獲得超2個(gè)贊
據(jù)我了解，您根本不需要 WaitGroup，您只需要重新排序genVals函數(shù)循環(huán)中的語句：
for i := 0; i < 10; i++ {
stream := make(chan interface{})
chanStream <- stream
stream <- i
close(stream)
}
https://go.dev/play/p/7D9OzrsvZyi
茅侃侃
TA貢獻(xiàn)1842條經(jīng)驗(yàn) 獲得超21個(gè)贊
有兩個(gè)主要問題。
第一期：
for i := 0; i < 10; i++ {
stream := make(chan interface{})
stream <- i
close(stream)
chanStream <- stream
}
創(chuàng)建后寫入無緩沖通道，沒有 goroutine 讀取。使用緩沖通道或其他 goroutine。
stream := make(chan interface{}, 1) // buffer size 1 to not block `stream <- i`
第二期：不
使用。 您可以在這兩種情況下使用。wg.Add(1)wg.Done()
defer
wg.Add(1)
defer wg.Done()
- 2 回答
- 0 關(guān)注
- 164 瀏覽
添加回答
舉報(bào)
0/150
提交
取消