通道上的基本发送和接收操作是阻塞的。然而,我们可以使用带有 default 子句的 select 来实现非阻塞的发送、接收,甚至是非阻塞的多路选择。
package main
import "fmt"
func main() {
messages := make(chan string)
signals := make(chan bool)
// 这是一个非阻塞的接收。如果 messages 通道中有值,select 会选择 <-messages 这一 case 并获取该值。如果没有值,它会立即选择 default case。
select {
case msg := <-messages:
fmt.Println("received message", msg)
default:
fmt.Println("no message received")
}
// 非阻塞的发送类似。这里,msg 无法发送到 messages 通道,因为该通道没有缓冲区且没有接收者。因此,选择了 default case。
msg := "hi"
select {
case messages <- msg:
fmt.Println("sent message", msg)
default:
fmt.Println("no message sent")
}
// 我们可以在 default 子句之前使用多个 case 来实现多路非阻塞选择。在这里,我们尝试对 messages 和 signals 通道进行非阻塞接收。
select {
case msg := <-messages:
fmt.Println("received message", msg)
case sig := <-signals:
fmt.Println("received signal", sig)
default:
fmt.Println("no activity")
}
}运行结果:
$ go run non-blocking-channel-operations.go
no message received
no message sent
no activity原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。