Go 的通道选择器 让你可以同时等待多个通道操作。Go 协程和通道以及选择器的结合是 Go 的一个强大特性。
package main
import "time" import "fmt"
func main() {
在我们的例子中,我们将从两个通道中选择。
c1 := make(chan string) c2 := make(chan string)
各个通道将在若干时间后接收一个值,这个用来模拟例如并行的 Go 协程中阻塞的 RPC 操作
go func() { time.Sleep(time.Second * 1) c1 <- "one" }() go func() { time.Sleep(time.Second * 2) c2 <- "two" }()
我们使用 select 关键字来同时等待这两个值,并打印各自接收到的值。
select
for i := 0; i < 2; i++ { select { case msg1 := <-c1: fmt.Println("received", msg1) case msg2 := <-c2: fmt.Println("received", msg2) } } }
我们首先接收到值 "one",然后就是预料中的 "two"了。
"one"
"two"
$ time go run select.go received one received two
注意从第一次和第二次 Sleeps 并发执行,总共仅运行了两秒左右。
Sleeps
real 0m2.245s
下一个例子: 超时处理.
@mmcgrana 编写 | everyx 翻译 | 项目地址 | license