我是go的初学者，我今天写了一个问题代码。本意是让资源生成和消费的时候同时打印出该资源信息。
但是该程序会导致死锁，有没有什么解决方法能保证输出信息和管道同步
```go
var mu sync.Mutex
func produce(ch chan<- int){
for i:=0;i<10;i++{
mu.Lock()
ch<-i
fmt.Println("produce:"+strconv.Itoa(i))
mu.Unlock()
}
}
func consumer(ch <- chan int){
for i:=0;i<10;i++{
mu.Lock()
v:=<-ch
fmt.Println("consumer:"+strconv.Itoa(v))
mu.Unlock()
}
}
func main(){
ch:=make(chan int,5)
go produce(ch)
go consumer(ch)
time.Sleep(10*time.Second)
}
```
```
var s1, s2 = make(chan int, 1), make(chan int, 1)
var wg sync.WaitGroup = sync.WaitGroup{}
func produce(ch chan<- int) {
for i := 0; i < 10; i++ {
<-s1
ch <- i
fmt.Println("produce:" + strconv.Itoa(i))
s2 <- 1
}
close(s2)
wg.Done()
}
func consumer(ch <-chan int) {
for i := 0; i < 10; i++ {
<-s2
v := <-ch
fmt.Println("consumer:" + strconv.Itoa(v))
s1 <- 1
}
close(s1)
wg.Done()
}
func main() {
ch := make(chan int, 1)
wg.Add(2)
s1 <- 1
go consumer(ch)
go produce(ch)
wg.Wait()
}
```
#12
更多评论
个人理解不一定正确： produce在执行第五次的时候，ch已经执行mu.Lock(),此时ch已满，通道阻塞，但是mu.Unlocl没有释放锁，所以造成了持续阻塞。
#1
今日阅读排行
一周阅读排行