select

select #

Go 的 选择器(select) 让你可以同时等待多个通道操作。

将协程、通道和选择器结合,是 Go 的一个强大特性。

// 在这个例子中,我们将从两个通道中选择。
c1 := make(chan string)
c2 := make(chan string)

// 各个通道将在一定时间后接收一个值,
// 通过这种方式来模拟并行的协程执行(例如,RPC 操作)时造成的阻塞(耗时)。
go func() {
    time.Sleep(1 * time.Second)
    c1 <- "one"
}()
go func() {
    time.Sleep(2 * time.Second)
    c2 <- "two"
}()

// 我们使用 `select` 关键字来同时等待这两个值,
// 并打印各自接收到的值。
for i := 0; i < 2; i++ {
    select {
    case msg1 := <-c1:
        fmt.Println("received", msg1)
    case msg2 := <-c2:
        fmt.Println("received", msg2)
    }
}

随机选则 #

除 default 外,如果有多个 case 语句评估通过,那么通过伪随机的方式随机选一个

非阻塞 #

default 为空 #

func sendTime(c interface{}, seq uintptr) {
	// Non-blocking send of time on c.
	// Used in NewTimer, it cannot block anyway (buffer).
	// Used in NewTicker, dropping sends on the floor is
	// the desired behavior when the reader gets behind,
	// because the sends are periodic.
	select {
	case c.(chan Time) <- Now():
	default:
	}
}

本文访问量

本站总访问量

本站总访客数