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語句塊執行的時候,實際上可以模擬成對乙個...