我試圖弄清楚為什么我有一個帶有等待組的死鎖。等待（）package mainimport ( "fmt" "sync")var wg sync.WaitGroupfunc foo(c chan int, i int) { defer wg.Done() c <- i}func main() { ch := make(chan int) for i := 0; i < 10; i++ { wg.Add(1) go foo(ch, i) } wg.Wait() close(ch) for item := range ch { fmt.Println(item) }}當我像這樣運行它時，它會打印fatal error: all goroutines are asleep - deadlock!我試圖更改為緩沖通道，這解決了問題。但我真的很想知道為什么會有死鎖。ch
1 回答
慕碼人8056858
TA貢獻1803條經驗 獲得超6個贊
我已經注釋掉了程序邏輯不正確的部分：
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
func foo(c chan int, i int) {
defer wg.Done()
c <- i
}
func main() {
ch := make(chan int) // unbuffered channel
for i := 0; i < 10; i++ {
wg.Add(1)
go foo(ch, i)
}
// wg.Wait is waiting for all goroutines to finish but that's
// only possible if the send to channel succeeds. In this case,
// it is not possible as your receiver "for item := range ch" is below
// this. Hence, a deadlock.
wg.Wait()
// Ideally, it should be the sender's duty to close the channel.
// And closing a channel before the receiver where the channel
// is unbuffered is not correct.
close(ch)
for item := range ch {
fmt.Println(item)
}
}
更正的程序：
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
func foo(c chan int, i int) {
defer wg.Done()
c <- i
}
func main() {
ch := make(chan int)
go func() {
for item := range ch {
fmt.Println(item)
}
}()
for i := 0; i < 10; i++ {
wg.Add(1)
go foo(ch, i)
}
wg.Wait()
close(ch)
}
- 1 回答
- 0 關注
- 81 瀏覽
添加回答
舉報
0/150
提交
取消