如何在不产生死锁的情况下拥有一个缓冲通道和多个读取器?
How can I have one buffered channel and multiple readers without producing a deadlock?
FATAL Error All go routines are asleep. Deadlock.
这是我试过的。我打电话给wg.Done()
。缺少什么?
package main
import (
"fmt"
"strconv"
"sync"
)
func sender(wg *sync.WaitGroup, cs chan int) {
defer wg.Done()
for i := 0; i < 2; i++ {
fmt.Println(i)
cs <- i
}
}
func reciever(wg *sync.WaitGroup, cs chan int) {
x, ok := <-cs
for ok {
fmt.Println("Retrieved" + strconv.Itoa(x))
x, ok = <-cs
if !ok {
wg.Done()
break
}
}
}
func main() {
wg := &sync.WaitGroup{}
cs := make(chan int, 1000)
wg.Add(1)
go sender(wg, cs)
for i := 1; i < 30; i++ {
wg.Add(1)
go reciever(wg, cs)
}
wg.Wait()
close(cs)
}
您应该在 wg.Wait
之前关闭频道。
您所有的接收器都在等待来自通道的数据。这就是你陷入僵局的原因。
您可以在 sender
函数的 defer
语句处关闭频道。
如果第一次尝试从频道接收失败(因为频道已经关闭),你还需要 wg.Done()
有几件事:
- 发送完成后您需要关闭频道。
- 在接收器中,范围超过通道
- 等待组不需要加1,在sender中调用Done
FATAL Error All go routines are asleep. Deadlock.
这是我试过的。我打电话给wg.Done()
。缺少什么?
package main
import (
"fmt"
"strconv"
"sync"
)
func sender(wg *sync.WaitGroup, cs chan int) {
defer wg.Done()
for i := 0; i < 2; i++ {
fmt.Println(i)
cs <- i
}
}
func reciever(wg *sync.WaitGroup, cs chan int) {
x, ok := <-cs
for ok {
fmt.Println("Retrieved" + strconv.Itoa(x))
x, ok = <-cs
if !ok {
wg.Done()
break
}
}
}
func main() {
wg := &sync.WaitGroup{}
cs := make(chan int, 1000)
wg.Add(1)
go sender(wg, cs)
for i := 1; i < 30; i++ {
wg.Add(1)
go reciever(wg, cs)
}
wg.Wait()
close(cs)
}
您应该在 wg.Wait
之前关闭频道。
您所有的接收器都在等待来自通道的数据。这就是你陷入僵局的原因。
您可以在 sender
函数的 defer
语句处关闭频道。
如果第一次尝试从频道接收失败(因为频道已经关闭),你还需要 wg.Done()
有几件事:
- 发送完成后您需要关闭频道。
- 在接收器中,范围超过通道
- 等待组不需要加1,在sender中调用Done