我是新手golang，我對這個僵局感到困惑（在這里運行）package mainimport ( "fmt" "runtime" "time")func main() { c := make(chan string) work := make(chan int, 1) clvl := runtime.NumCPU() count := 0 for i := 0; i < clvl; i++ { go func(i int) { for jdId := range work { time.Sleep(time.Second * 1) c <- fmt.Sprintf("done %d", jdId) } }(i) } go func() { for i := 0; i < 10; i++ { work <- i } close(work) }() for resp := range c { fmt.Println(resp, count) count += 1 }}
1 回答
泛舟湖上清波郎朗
TA貢獻1818條經驗 獲得超3個贊
你永遠不會 close c，所以你的for range循環永遠等待。像這樣關閉它：
var wg sync.WaitGroup
for i := 0; i < clvl; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
for jdId := range work {
time.Sleep(time.Second * 1)
c <- fmt.Sprintf("done %d", jdId)
}
}(i)
}
go func() {
for i := 0; i < 10; i++ {
work <- i
}
close(work)
wg.Wait()
close(c)
}()
編輯：修復了恐慌，感謝 Crast
- 1 回答
- 0 關注
- 180 瀏覽
添加回答
舉報
0/150
提交
取消