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

Go Channels 行为似乎不一致

Go Channels 行为似乎不一致

Go
开心每一天1111 2021-09-13 14:38:18
我发现无缓冲通道的工作方式不一致 - 这要么是 Go 中的不一致,要么是我对 Go 的理解......这是一个带有输出的简单示例。“不一致”与“制造渠道”线有关。package mainimport (    "fmt"    )func send(sendto chan string) {    fmt.Println("send 1")    sendto <- "Hello"    fmt.Println("send 2")    sendto <- "World"    fmt.Println("send 3")    sendto <- ""    fmt.Println("send() exit")}func main() {    //hole := make(chan string)    //hole := make(chan string, 0)    hole := make(chan string, 1)    go send(hole)    fmt.Println("main loop")    carryon := true    for carryon {        msg := <- hole        if msg == "" {            carryon = false        } else {            fmt.Println(" recd ", msg)        }    }}当我按上述方式运行时,输出符合预期(对于缓冲区大小为 2 的情况也符合预期)。即通道有一个缓冲区为 1,它保存一个值 - 在下一次尝试写入时,有一个上下文切换到 main 以允许它使用第一个值。main loopsend 1send 2 recd  Hellosend 3 recd  Worldsend() exit当我将 make 通道行更改为:hole := make(chan string, 0)输出是:main loopsend 1send 2 recd  Hello recd  Worldsend 3send() exit我原以为send 2和 是recd Hello相反的......我得到相同的输出 hole := make(chan string)我检查了规范,它说容量(以元素数为单位)设置通道中缓冲区的大小。如果容量为零或不存在,则通道没有缓冲,只有当发送方和接收方都准备好时,通信才能成功。否则,如果缓冲区未满(发送)或非空(接收),则通道被缓冲并且通信成功而不会阻塞。请有人解释一下为什么我的期望是错误的 - 请善待或者 Go 是否真的错了谢谢
查看完整描述

3 回答

?
蝴蝶不菲

TA贡献1810条经验 获得超4个赞

这两个 goroutine 的时间线显示了正在发生的事情:


send()                  main()


fmt.Println("send 1")

sendto <- "Hello"       msg := <- hole              // sender and receiver both ready

fmt.Println("send 2")

                        fmt.Println(" recd ", msg)  // msg is "Hello"

sendto <- "World"       msg := <- hole              // sender and receiver both ready

                        fmt.Println(" recd ", msg)  // msg is "World"

fmt.Println("send 3")

sendto <- ""

fmt.Println("send() exit")

send 2之前打印,recd Hello因为 send() 在运行时调度 main() 再次运行之前运行到打印语句。


打印两条消息的关系之前没有发生。它们可以按任一顺序打印。


查看完整回答
反对 回复 2021-09-13
?
繁星点点滴滴

TA贡献1803条经验 获得超3个赞

大致:发送和接收同时发生。详细信息在决定此行为的 Go Memory Model 中进行了解释。并发代码很复杂...


查看完整回答
反对 回复 2021-09-13
?
holdtom

TA贡献1805条经验 获得超10个赞

只有当发送方和接收方都准备好时,通信才会成功

关键是这不需要接收方立即开始处理它收到的消息。特别是在您的情况下,它已准备就绪,因此它无需调用调度程序即可接收该值(无上下文切换)。goroutine 继续运行,直到它再次尝试发送,此时接收器还没有准备好,因此调度程序被调用等。


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

添加回答

举报

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