在某些場景下我們需要同時從多個通道接收數據。通道在接收數據時，如果沒有數據可以接收將會發生阻塞，而select就可以同時監聽一個或多個channel，直到其中一個channel準備好。

select的使用類似于switch語句，它有一系列case分支和一個默認的分支。每個case會對應一個通道的通信（接收或發送）過程。select會一直等待，直到某個case的通信操作完成時，就會執行case分支對應的語句。具體格式如下：

select {case <-chan1:// 如果chan1成功讀到數據，則進行該case處理語句case chan2 <- 1:// 如果成功向chan2寫入數據，則進行該case處理語句default:// 如果上面都沒有成功，則進入default處理流程} package mainimport ("fmt""time" )func test1(ch chan string) {time.Sleep(time.Second * 1)ch <- "test1" } func test2(ch chan string) {time.Sleep(time.Second * 2)ch <- "test2" }func main() {// 2個管道output1 := make(chan string)output2 := make(chan string)// 跑2個子協程，寫數據go test1(output1)go test2(output2)for {// 用select監控select {case s1 := <-output1:fmt.Println("s1=", s1)case s2 := <-output2:fmt.Println("s2=", s2)default:ticker := time.NewTicker(1 * time.Second)fmt.Printf("%v\n", <-ticker.C)}} }

判斷通道是否已經存滿

package mainimport ("fmt""time" )// 判斷管道有沒有存滿 func main() {// 創建管道output1 := make(chan string, 1)// 子協程寫數據go write(output1)// 取數據for s := range output1 {fmt.Println("res:", s)time.Sleep(time.Second)} }func write(ch chan string) {for {select {// 寫數據case ch <- "hello":fmt.Println("write hello")default:fmt.Println("channel full")}time.Sleep(time.Millisecond * 500)} }

總結

以上是生活随笔為你收集整理的Select多路复用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。