缓冲和非缓冲通道会出现问题

kok*_*oko 3 go

我对 Go 中缓冲通道和非缓冲通道之间的区别有点困惑。例如,下面的代码执行良好:

package main

import "fmt"

func main() {
    messages := make(chan string)
    go func() { messages <- "ping" }()
    msg := <-messages
    fmt.Println(msg)
}
Run Code Online (Sandbox Code Playgroud)

另一方面,当我"ping"在常规函数中传递消息时,会出现死锁。

package main

import "fmt"

func main() {
    messages := make(chan string)
    func() { messages <- "ping" }()
    msg := <-messages
    fmt.Println(msg)
}
Run Code Online (Sandbox Code Playgroud)

最后,当我使用缓冲通道时,这个问题得到了解决,如下所示

package main

import "fmt"

func main() {
    messages := make(chan string, 1)
    func() { messages <- "ping" }()
    msg := <-messages
    fmt.Println(msg)
}
Run Code Online (Sandbox Code Playgroud)

我很困惑为什么第二个案例失败了。举例说明

默认情况下,通道是无缓冲的,这意味着如果有相应的接收 (<- chan) 准备好接收发送的值,它们只会接受发送 (chan <-)。缓冲通道接受有限数量的值,而没有这些值的相应接收器。

msg在这三种情况下,水槽不是用于吗messages

ajo*_*eps 5

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

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

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

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