golang 无缓冲信道接受数据造成阻塞的问题

Olinda ·

更新时间:2024-11-15

· 527 次阅读

今天翻开之前的笔记，遇到点问题

chs := make([]chan int, 10)
for i := 0; i >>>> send ", i) 
        chs[i] <- i
    }(i)
}
for _, ch := range chs {
    value := <-ch
    close(ch)
    fmt.Println("<<<<< receive ", value)
}
fmt.Println("All done")

这段代码，时好时坏，大部分时间报错： all goroutines are asleep - deadlock!（死锁）

原因是，main函数从chs（都是无缓冲的信道）中接受数据，第一个ch不一定已经准备好发送的数据，换句话说main函数被阻塞了，此时不能在继续往下执行了

换个简单点的实验代码

ch := make(chan int)
value := <-ch
fmt.Println(value)
ch <- 5
fmt.Println("done")

顺序执行，先接受，后发送，那肯定会被阻塞，

可以以协程的方式进行发送和接受

ch := make(chan int)
go func() {
    ch <- 1
}()
go func() {
    value := <-ch
    fmt.Println(value)
}()
time.Sleep(time.Millisecond) // 等待一毫秒，让协程的print输出内容
fmt.Println("done")

所以出问题的代码有两种解决方式 在两个for循环之间，sleep，让所有发送都就绪接受的for循环，和发送的方式一样，也放在协程中执行 ***2020/1/17 半夜睡不着，好像哪里不对劲，思来想去，原来是这样的***

代码会有问题，不是因为channel没有准备好，是因为chs数组没有初始化完成，每个ch是在协程内部创建的，range的时候，第一个可能还没创建好
，于是修改代码，测试

chs := make([]chan int, 10)
// main协程中先初始化
for i := 0; i < 10; i++ {
    chs[i] = make(chan int)
}
for i := 0; i >>>> send ", i) 
        chs[i] <- i
    }(i)
}
for _, ch := range chs {
    value := <-ch
    close(ch)
    fmt.Println("<<<<< receive ", value)
}
fmt.Println("All done")

果然，哈哈哈。。
希望没有坑人吧

作者：glqEason

无缓冲缓冲数据 golang

1024 个赞