golang開發 select多路選擇

2022-06-25 09:36:12 字數 2428 閱讀 1774

select 是 golang 中的乙個控制結構,語法上類似於switch 語句,只不過select是用於 goroutine 間通訊的 ,每個 case 必須是乙個通訊操作,要麼是傳送要麼是接收,select 會隨機執行乙個可執行的 case。如果沒有 case 可執行,goroutine 將阻塞,直到有 case 可執行。

select寫法上跟switch case的寫法基本一致,只不過golang的select是通訊控制語句。select的執行必須有通訊的傳送或者接受,如果沒有就一直阻塞。

ch := make(chan bool, 0)

ch1 := make(chan bool, 0)

select

如果ch和ch1都沒有通訊資料傳送,select就一直阻塞,直到ch或者ch1有資料傳送,select就執行相應的case來接受資料。

我們可以利用select機制實現一種簡單的超時控制。

先看下程式完整執行的**

func service(ch chan bool) 

func main()

}___go_build_main_go #gosetup

true

可以看到使用time.after超時定義了5s,service程式執行3s,所以肯定沒有超時,跟預想的一致。

我們再看看超時的執行,我們將service程式執行時間該為6s。超時控制繼續是5s,再看下執行效果

func service(ch chan bool) 

func main()

}___go_build_main_go #gosetup

timeout

執行到了超時的case,跟預想的其實是一致的。

先看下接受資料的語法

val,ok <- ch

ok true 正常接收資料

ok false 通道關閉

可以看到接受資料其實有兩個引數,第二個bool值會反應channel是否關閉,是否可以正常接受資料。

看下測試**

我們寫了乙個資料傳送者,兩個資料接收者,當傳送者關閉channel的時候,兩個接收者的 goroutine 可以通過以上的語法判斷channel是否關閉,決定自己的 goroutine 是否結束。

func sender(ch chan int, wg *sync.waitgroup) 

close(ch)

wg.done()

}func receiver(ch chan int, wg *sync.waitgroup) else

} wg.done()

}func receiver2(ch chan int, wg *sync.waitgroup) else

} wg.done()

}func main()

wg.add(1)

go sender(ch, wg)

wg.add(1)

go receiver(ch, wg)

wg.add(1)

go receiver2(ch, wg)

wg.wait()

}

執行結果

0,revevier2

2,revevier2

3,revevier2

4,revevier2

5,revevier2

6,revevier2

7,revevier2

1,revevier

9,revevier

quit recevier

8,revevier2

quit recevier2

可以看到乙個資料傳送者,兩個資料接收者,當channel關閉的時候,兩個資料接收者都收到了channel關閉的通知。

需要注意的是,給乙個已經關閉的channel傳送資料,程式會panic,從乙個已經關閉的channel接收資料,會接收到沒有參考意義的channel型別的0值資料,int是0,string是空...

開發中經常會經常會使用輪訓計時器,但是當程式退出時,輪訓計時器無法關閉的問題。其實select是可以解決這個問題的。

如果我們有乙個輪訓任務,需要乙個timer,每隔3s執行邏輯,過完10s之後關閉這個timer。

看下**

func timetick(wg *sync.waitgroup,q chan bool) 	}}

func main()

執行結果

seconds timer

seconds timer

seconds timer

quit

很優雅的通過關閉channel退出了輪訓計時器 goroutine,

Golang併發模型 select高階

最近公司工作有點多,golang的select高階就這樣被拖沓啦,今天堅持把時間擠一擠,把吹的牛皮補上。前一篇文章 golang併發模型 輕鬆入門select 介紹了select的作用和它的基本用法,這次介紹它的3個高階特性。nil的通道永遠阻塞 如何跳出for selectselect 阻塞 當c...

golang學習筆記 select 3

從不同併發執行的協程中,獲取資料可以用select來完成。select監聽的多個通道,也可以用通道傳送數值。select 1 如果多個通道都阻塞了,會等待直到其中乙個通道可以處理。2 如果多個通道都可以處理,隨機選取乙個處理。3 如果沒有通道操作可以操作並且寫了default語句,會執行 defau...

golang的select實現原理剖析

select為golang提供了多路io復用機制,和其他io復用一樣,用於檢測是否有讀寫事件是否ready。本文將介紹一下golang的select的用法和實現原理。golang實現select的時候,實際上為每乙個case語句定義了乙個資料結構,select語句塊執行的時候,實際上可以模擬成對乙個...