我试着用channel写一些goroutine,但是死锁了,为什么?我是不是对WaitGroup做错了,如此困惑...
package main
import (
"fmt"
"sync"
)
var wg sync.WaitGroup
func main() {
chan1 := make(chan string)
chan2 := make(chan string)
chan3 := make(chan string, 2)
wg.Add(1)
go makeChanStr("yeye", chan1, chan3)
wg.Add(1)
go makeChanStr("okok", chan2, chan3)
wg.Wait()
close(chan3)
println(<-chan1)
println(<-chan2)
for chs := range chan3 {
println(chs)
}
}
func makeChanStr(s string, c1 chan string, c2 chan string) {
defer wg.Done()
c1 <- "get " + s
c2 <- "same value"
fmt.Printf("execute ok %s", s)
}Stackoverflow只是不让我提交question.......so,我只需要添加一些文本.....
发布于 2021-06-08 21:37:57
wg.Wait()上的main块,它等待这两个go例程完成(由于wg.Add(1)和wg.Done())
go makeChanStr("yeye", chan1, chan3)
go makeChanStr("okok", chan2, chan3)但它们在chan1 (或chan2)上阻塞,因为它是一个无缓冲通道。
chan1 := make(chan string)尝试将chan1和chan2更改为buffer channels:
chan1 := make(chan string,1)
chan2 := make(chan string,1)https://stackoverflow.com/questions/67887932
复制相似问题