快捷導(dǎo)航

詳解Go語(yǔ)言中select語(yǔ)句的常見(jiàn)用法

更新時(shí)間：2023年07月19日 08:30:37 作者：AlwaysBeta

這篇文章主要是來(lái)和大家介紹一下Go語(yǔ)言中select?語(yǔ)句的常見(jiàn)用法，以及在使用過(guò)程中的注意事項(xiàng)，文中的示例代碼講解詳細(xì)，感興趣的小伙伴可以了解一下

基本語(yǔ)法

select 語(yǔ)句的基本語(yǔ)法如下：

select?{
case?<-channel1:
????//?通道?channel1?就緒時(shí)的處理邏輯
case?data?:=?<-channel2:
????//?通道?channel2?就緒時(shí)的處理邏輯
default:
????//?當(dāng)沒(méi)有任何通道就緒時(shí)的默認(rèn)處理邏輯
}

看到這個(gè)語(yǔ)法，很容易想到 switch 語(yǔ)句。

雖然 select 語(yǔ)句和 switch 語(yǔ)句在表面上有些相似，但它們的用途和功能是不同的。

switch 用于條件判斷，而 select 用于通道操作。不能在 select 語(yǔ)句中使用任意類型的條件表達(dá)式，只能對(duì)通道進(jìn)行操作。

使用規(guī)則

雖然語(yǔ)法簡(jiǎn)單，但是在使用過(guò)程中，還是有一些地方需要注意，我總結(jié)了如下四點(diǎn)：

select 語(yǔ)句只能用于通道操作，用于在多個(gè)通道之間進(jìn)行選擇，以監(jiān)聽(tīng)通道的就緒狀態(tài)，而不是用于其他類型的條件判斷。
select 語(yǔ)句可以包含多個(gè) case 子句，每個(gè) case 子句對(duì)應(yīng)一個(gè)通道操作。當(dāng)其中任意一個(gè)通道就緒時(shí)，相應(yīng)的 case 子句會(huì)被執(zhí)行。
如果多個(gè)通道都已經(jīng)就緒，select 語(yǔ)句會(huì)隨機(jī)選擇一個(gè)通道來(lái)執(zhí)行。這樣確保了多個(gè)通道之間的公平競(jìng)爭(zhēng)。
select 語(yǔ)句的執(zhí)行可能是阻塞的，也可能是非阻塞的。如果沒(méi)有任何一個(gè)通道就緒且沒(méi)有默認(rèn)的 default 子句，select 語(yǔ)句會(huì)阻塞，直到有一個(gè)通道就緒。如果有 default 子句，且沒(méi)有任何通道就緒，那么 select 語(yǔ)句會(huì)執(zhí)行 default 子句，從而避免阻塞。

多路復(fù)用

select 最常見(jiàn)的用途之一，同時(shí)監(jiān)聽(tīng)多個(gè)通道，并根據(jù)它們的就緒狀態(tài)執(zhí)行不同的操作。

package?main
import?(
????"fmt"
????"time"
)
func?main()?{
????c1?:=?make(chan?string)
????c2?:=?make(chan?string)
????go?func()?{
????????time.Sleep(3?*?time.Second)
????????c1?<-?"one"
????}()
????go?func()?{
????????time.Sleep(3?*?time.Second)
????????c2?<-?"two"
????}()
????select?{
????case?msg?:=?<-c1:
????????fmt.Println(msg)
????case?msg?:=?<-c2:
????????fmt.Println(msg)
????}
}

執(zhí)行上面的代碼，程序會(huì)隨機(jī)打印 one 或者 two，如果通道為空的話，程序就會(huì)一直阻塞在那里。

非阻塞通信

當(dāng)通道中沒(méi)有數(shù)據(jù)可讀或者沒(méi)有緩沖空間可寫(xiě)時(shí)，普通的讀寫(xiě)操作將會(huì)阻塞。

但通過(guò) select 語(yǔ)句，我們可以在沒(méi)有數(shù)據(jù)就緒時(shí)執(zhí)行默認(rèn)的邏輯，避免程序陷入無(wú)限等待狀態(tài)。

package?main
import?(
????"fmt"
)
func?main()?{
????channel?:=?make(chan?int)
????select?{
????case?data?:=?<-channel:
????????fmt.Println("Received:",?data)
????default:
????????fmt.Println("No?data?available.")
????}
}

執(zhí)行上面代碼，程序會(huì)執(zhí)行 default 分支。

輸出：

No data available.

超時(shí)處理

通過(guò)結(jié)合 select 和 time.After 函數(shù)，我們可以在指定時(shí)間內(nèi)等待通道就緒，超過(guò)時(shí)間后執(zhí)行相應(yīng)的邏輯。

package?main
import?(
????"fmt"
????"time"
)
func?main()?{
????channel?:=?make(chan?int)
????select?{
????case?data?:=?<-channel:
????????fmt.Println("Received:",?data)
????case?<-time.After(3?*?time.Second):
????????fmt.Println("Timeout?occurred.")
????}
}

執(zhí)行上面代碼，如果 channel 在 3 秒內(nèi)沒(méi)有數(shù)據(jù)可讀，select 會(huì)執(zhí)行 time.After 分支。

輸出：