Non-Blocking Channel Operations->非阻塞通道操作 #

// 常规的通过通道发送和接收数据是阻塞的。
// 然而，我们可以使用带一个 `default` 子句的 `select`
// 来实现 _非阻塞_ 的发送、接收，甚至是非阻塞的多路 `select`。

package main

import "fmt"

func main() {
	messages := make(chan string)
	signals := make(chan bool)

	// 这是一个非阻塞接收的例子。
	// 如果在 `messages` 中存在，然后 `select` 将这个值带入 `<-messages` `case` 中。
	// 否则，就直接到 `default` 分支中。
	select {
	case msg := <-messages:
		fmt.Println("received message", msg)
	default:
		fmt.Println("no message received")
	}

	// 一个非阻塞发送的例子，代码结构和上面接收的类似。
	// `msg` 不能被发送到 `message` 通道，因为这是
	// 个无缓冲区通道，并且也没有接收者，因此， `default`
	// 会执行。
	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