为了账号安全,请及时绑定邮箱和手机立即绑定

使用缓冲和非缓冲通道遇到麻烦

使用缓冲和非缓冲通道遇到麻烦

Go
holdtom 2022-06-13 16:17:22
我对 Go 中缓冲通道和无缓冲通道之间的区别有点困惑。例如,下面的代码执行良好:package mainimport "fmt"func main() {    messages := make(chan string)    go func() { messages <- "ping" }()    msg := <-messages    fmt.Println(msg)}另一方面,当我"ping"在常规函数中传递消息时,会出现死锁。package mainimport "fmt"func main() {    messages := make(chan string)    func() { messages <- "ping" }()    msg := <-messages    fmt.Println(msg)}最后,当我使用缓冲通道时,这是固定的,就像这样package mainimport "fmt"func main() {    messages := make(chan string, 1)    func() { messages <- "ping" }()    msg := <-messages    fmt.Println(msg)}我很困惑为什么第二个案例失败了。Go By Example 说默认情况下,通道是无缓冲的,这意味着如果有相应的接收 (<- chan) 准备好接收发送的值,它们将只接受发送 (chan <-)。缓冲通道接受有限数量的值,而这些值没有相应的接收器。msg在所有三种情况下,水槽不是用于messages吗?
查看完整描述

3 回答

?
呼啦一阵风

TA贡献1802条经验 获得超6个赞

如果未读取无缓冲通道,则它们会阻塞。缓冲通道在达到容量之前不会阻塞。

您的第一个示例实际上启动了一个单独的 go 例程,该例程执行尝试将“ping”写入消息通道的函数。它将阻塞,直到从消息通道读取的语句执行。从消息通道读取的语句能够被命中,因为该函数位于单独的 goroutine 上。

您的第二个示例声明并调用了一个尝试写入消息通道的函数,但该通道永远不会准备好写入,因为您正在同一个主执行线程上执行。从消息通道读取的语句永远不会命中,因为您在写入通道时被阻止。

第三个例子,通道被缓冲并且可以被写入,因为它可以在阻塞之前接受 1 个值。


查看完整回答
反对 回复 2022-06-13
?
宝慕林4294392

TA贡献2021条经验 获得超8个赞

您可能已经浏览了那里的一个关键词:“如果有相应的接收 (<- chan)准备好接收发送的值”。

在您的第一个示例中,接收器与发送器同时运行,因此当发送器发送时,接收器此时已准备好接收。在第二个例子中,它们不是并发运行的,所以当发送者发送时,没有准备好接收(因为接收操作在匿名函数返回之前不会运行),并且发送阻塞。


查看完整回答
反对 回复 2022-06-13
?
忽然笑

TA贡献1806条经验 获得超5个赞

在第一个示例中,嵌套函数是从另一个 goroutine 调用的。该函数开始运行并阻塞等待写入通道。主 goroutine 也运行,并从通道读取,释放第二个 goroutine 中的块。

在第二个示例中,嵌套函数由 main 调用,main 等待它返回。由于通道没有缓冲,写操作阻塞,这意味着主协程被阻塞,没有其他协程,所以死锁。

在第三个示例中,通道被缓冲,因此第一次写入不会阻塞。


查看完整回答
反对 回复 2022-06-13
  • 3 回答
  • 0 关注
  • 83 浏览
慕课专栏
更多

添加回答

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信