Go语言select
select是什么
select
是Go语言层面提供的一种多路复用机制,用于检测当前goroutine
连接的多个channel
是否有数据准备完毕,可用于读或写。
Go语言的select
语句,是用来起一个goroutine
监听多个Channel
的读写事件,提高从多个Channel
获取信息的效率,相当于是单线程处理多个IO事件,其思想基本相同。
select的用法
select
的基本使用模式如下:
select {case <- channel1: // 如果从channel1读取数据成功,执行case语句 do ... case channel2 <- 1: // 如果向channel2写入数据成功,执行case语句 do ... default: // 如果上面都没有成功,进入default处理流程do ...
}
可以看到,select
的用法形式类似于switch
,但是区别于switch
的是,select
各个case
的表达式必须都是channel
的读写操作。select
通过多个case
语句监听多个channel
的读写操作是否准备好可以执行,其中任何一个case
可以执行了则选择该case
语句执行,如果没有可以执行的case
,则执行default
语句,如果没有default
,则当前goroutine
会阻塞。
空select永久阻塞
当一个select
中什么语句都没有,没有任何case
,将会永久阻塞:
package mainfunc main() {select {}
}
运行结果:
fatal error: all goroutines are asleep - deadlock!
程序因为select
语句导致永久阻塞,当前goroutine
阻塞之后,由于Go语言自带死锁检测机制,发现当前goroutine
永远不会被唤醒,会报上述死锁错误。
没有default且case无法执行的select永久阻塞
看下面示例:
package mainimport ("fmt"
)func main() {ch1 := make(chan int, 1)ch2 := make(chan int, 1)select {case <-ch1:fmt.Printf("received from ch1")case num := <-ch2:fmt.Printf("num is: %d", num)}
}
运行结果:
fatal error: all goroutines are asleep - deadlock!
程序中 select
从两个channel
,ch1
和ch2
中读取数据,但是两个channel
都没有数据,且没有goroutine
往里面写数据,所以不可能读到数据,这两个case
永远无法执行到,select
也没有default
,所以会出现永久阻塞,报死锁。
单一case和default的select
package mainimport ("fmt"
)func main() {ch := make(chan int, 1)select {case <-ch:fmt.Println("received from ch")default:fmt.Println("default!!!")}
}
运行结果:
default!!!
执行到select
语句的时候,由于ch
中没有数据,且没有goroutine
往channel
中写数据,所以case
不可能执行到,就会执行default
语句,打印出default!!!
。
多个case和default的select
package mainimport ("fmt""time"
)func main() {ch1 := make(chan int, 1)ch2 := make(chan int, 1)go func() {time.Sleep(time.Second)for i := 0; i < 3; i++ {select {case v := <-ch1:fmt.Printf("Received from ch1, val = %d\n", v)case v := <-ch2:fmt.Printf("Received from ch2, val = %d\n", v)default:fmt.Println("default!!!")}time.Sleep(time.Second)}}()ch1 <- 1time.Sleep(time.Second)ch2 <- 2time.Sleep(4 * time.Second)
}
运行结果:
Received from ch1, val = 1
Received from ch2, val = 2
default!!!
主goroutine
中向后往管道ch1
和ch2
中发送数据,在子goroutine
中执行两个select
,可以看到,在执行select
的时候,那个case
准备好了就会执行当下case
的语句,最后没有数据可接受了,没有case
可以执行,则执行default
语句。
注意:当多个case都准备好了的时候,会随机选择一个执行
package mainimport ("fmt"
)func main() {ch1 := make(chan int, 1)ch2 := make(chan int, 1)ch1 <- 5ch2 <- 6select {case v := <-ch1:fmt.Printf("Received from ch1, val = %d\n", v)case v := <-ch2:fmt.Printf("Received from ch2, val = %d\n", v)default:fmt.Println("default!!!")}
}
运行结果:
Received from ch2, val = 6
多次执行,2个case
都有可能打印,这就是select
选择的随机性。