快捷導(dǎo)航

golang中select語(yǔ)句的簡(jiǎn)單實(shí)例

更新時(shí)間：2022年06月29日 11:56:39 作者：燕雙鷹...

Go的select語(yǔ)句是一種僅能用于channl發(fā)送和接收消息的專用語(yǔ)句,此語(yǔ)句運(yùn)行期間是阻塞的,下面這篇文章主要給大家介紹了關(guān)于golang中select語(yǔ)句的相關(guān)資料,文中通過(guò)實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下

前言

在golang語(yǔ)言中，select語(yǔ)句就是用來(lái)監(jiān)聽(tīng)和channel有關(guān)的IO操作，當(dāng)IO操作發(fā)生時(shí)，觸發(fā)相應(yīng)的case動(dòng)作。有了 select語(yǔ)句，可以實(shí)現(xiàn) main主線程與 goroutine線程之間的互動(dòng)。

select {
    case <-ch1 :     // 檢測(cè)有沒(méi)有數(shù)據(jù)可讀
        // 一旦成功讀取到數(shù)據(jù)，則進(jìn)行該case處理語(yǔ)句
    case ch2 <- 1 :  // 檢測(cè)有沒(méi)有數(shù)據(jù)可寫(xiě)
        // 一旦成功向ch2寫(xiě)入數(shù)據(jù)，則進(jìn)行該case處理語(yǔ)句
    default:
        // 如果以上都沒(méi)有符合條件，那么進(jìn)入default處理流程
}

注意事項(xiàng)：

select語(yǔ)句只能用于channel信道的IO操作，每個(gè)case都必須是一個(gè)信道。
如果不設(shè)置 default條件，當(dāng)沒(méi)有IO操作發(fā)生時(shí)，select語(yǔ)句就會(huì)一直阻塞；
如果有一個(gè)或多個(gè)IO操作發(fā)生時(shí)，Go運(yùn)行時(shí)會(huì)隨機(jī)選擇一個(gè)case執(zhí)行，但此時(shí)將無(wú)法保證執(zhí)行順序；
對(duì)于case語(yǔ)句，如果存在信道值為nil的讀寫(xiě)操作，則該分支將被忽略，可以理解為相當(dāng)于從select語(yǔ)句中刪除了這個(gè)case；
對(duì)于空的 select語(yǔ)句，會(huì)引起死鎖；
對(duì)于在 for中的select語(yǔ)句，不能添加 default，否則會(huì)引起cpu占用過(guò)高的問(wèn)題；

1.先舉個(gè)簡(jiǎn)單例子

先創(chuàng)建兩個(gè)信道，并在 select 前往 c2 發(fā)送數(shù)據(jù)

package main
 
import (
	"fmt"
)
 
//go的通道選擇器 讓你可以同時(shí)等待多個(gè)通道操作。go協(xié)程和通道以及選擇器的結(jié)合是go的一個(gè)強(qiáng)大特性。
 
func main() {
	// 在我們的例子中，我們將從兩個(gè)通道中選擇。
	c1 := make(chan string, 1)
	c2 := make(chan string, 1)
 
	c2 <- "nihao"
 
	//go func() {
	//	time.Sleep(time.Second * 1)
	//	c1 <- "one"
	//}()
	//
	//go func() {
	//	time.Sleep(time.Second * 2)
	//	c2 <- "two"
	//}()
 
	//我們使用 `select` 關(guān)鍵字來(lái)同時(shí)等待這兩個(gè)值，并打印各自接收到的值。
	//for i := 0; i < 2; i++ {
	select {
	case msg1 := <-c1:
		fmt.Println("received", msg1)
	case msg2 := <-c2:
		fmt.Println("received", msg2)
	default:
		fmt.Println("No data received")
	}
	//}
 
}

在運(yùn)行 select 時(shí)，會(huì)遍歷所有（如果有機(jī)會(huì)的話）的 case 表達(dá)式，只要有一個(gè)信道有接收到數(shù)據(jù)，那么 select 就結(jié)束，所以輸出如下

2. 避免造成死鎖

select 在執(zhí)行過(guò)程中，必須命中其中的某一分支。

如果在遍歷完所有的 case 后，若沒(méi)有命中（命中：也許這樣描述不太準(zhǔn)確，我本意是想說(shuō)可以執(zhí)行信道的操作語(yǔ)句）任何一個(gè) case 表達(dá)式，就會(huì)進(jìn)入 default 里的代碼分支。

package main
 
import (
	"fmt"
)
 
//go的通道選擇器 讓你可以同時(shí)等待多個(gè)通道操作。go協(xié)程和通道以及選擇器的結(jié)合是go的一個(gè)強(qiáng)大特性。
 
func main() {
	// 在我們的例子中，我們將從兩個(gè)通道中選擇。
	c1 := make(chan string, 1)
	c2 := make(chan string, 1)
 
	//c2 <- "nihao"
 
	//go func() {
	//	time.Sleep(time.Second * 1)
	//	c1 <- "one"
	//}()
	//
	//go func() {
	//	time.Sleep(time.Second * 2)
	//	c2 <- "two"
	//}()
 
	//我們使用 `select` 關(guān)鍵字來(lái)同時(shí)等待這兩個(gè)值，并打印各自接收到的值。
	//for i := 0; i < 2; i++ {
	select {
	case msg1 := <-c1:
		fmt.Println("received", msg1)
	case msg2 := <-c2:
		fmt.Println("received", msg2)
		//default:
		//	fmt.Println("No data received")
		//}
	}
}

但如果你沒(méi)有寫(xiě) default 分支，select 就會(huì)阻塞，直到有某個(gè) case 可以命中，而如果一直沒(méi)有命中，select 就會(huì)拋出 deadlock 的錯(cuò)誤，就像下面這樣子。

1.解決這個(gè)問(wèn)題的方法有兩種

一個(gè)是，養(yǎng)成好習(xí)慣，在 select 的時(shí)候，也寫(xiě)好 default 分支代碼，盡管你 default 下沒(méi)有寫(xiě)任何代碼。

另一個(gè)是，讓其中某一個(gè)信道可以接收到數(shù)據(jù)

3. select 隨機(jī)性

之前學(xué)過(guò) switch 的時(shí)候，知道了 switch 里的 case 是順序執(zhí)行的，但在 select 里卻不是。

通過(guò)下面這個(gè)例子的執(zhí)行結(jié)果就可以看出

4. select 的超時(shí)

當(dāng) case 里的信道始終沒(méi)有接收到數(shù)據(jù)時(shí)，而且也沒(méi)有 default 語(yǔ)句時(shí)，select 整體就會(huì)阻塞，但是有時(shí)我們并不希望 select 一直阻塞下去，這時(shí)候就可以手動(dòng)設(shè)置一個(gè)超時(shí)時(shí)間。