我在爭論 goroutine 并讓他們與主要 goroutine 上的頻道進行交流時遇到了麻煩。為簡化起見，我的代碼如下所示：func main() { channel := make(chan string) var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) go performTest(channel, &wg, i) } wg.Wait() close(channel) for line := range channel { fmt.Print(line) }}func performTest(channel chan string, wg *sync.WaitGroup, i int) { defer wg.Done() // perform some work here result := fmt.sprintf("Pretend result %d", i) channel <- result}這似乎進入了某種僵局，但我不明白為什么。它卡住了wg.Wait()，即使我希望它在所有 goroutine 都調(diào)用Done等待組后繼續(xù)。我在這里想念什么？我想等待 goroutines，然后遍歷通道中的所有結(jié)果。
1 回答
收到一只叮咚
TA貢獻1821條經(jīng)驗 獲得超5個贊
您可以等待組并在單獨的 go 例程中關(guān)閉通道。如果通道關(guān)閉，您在通道上的范圍將在收到最后一個發(fā)送的值后結(jié)束。
如果您只是等待，則不會從頻道收到任何內(nèi)容。由于通道是無緩沖的，performTestgoroutines 將無法發(fā)送。對于無緩沖通道，發(fā)送操作將阻塞，直到它被接收。因此，延遲wg.Done調(diào)用永遠不會發(fā)生，您的程序就會陷入僵局。由于Done僅在執(zhí)行永久阻塞發(fā)送后調(diào)用。
func main() {
channel := make(chan string)
var wg sync.WaitGroup
for i := 0; i < 10; i++ {
wg.Add(1)
go performTest(channel, &wg, i)
}
// this is the trick
go func() {
wg.Wait()
close(channel)
}()
for line := range channel {
fmt.Print(line)
}
}
func performTest(channel chan string, wg *sync.WaitGroup, i int) {
defer wg.Done()
// perform some work here
result := fmt.Sprintf("Pretend result %d\n", i)
channel <- result
}
https://play.golang.com/p/5pACJzwL4Hi
- 1 回答
- 0 關(guān)注
- 109 瀏覽
添加回答
舉報
0/150
提交
取消