channel是Go語言中的一個核心類型,可以把它看成管道。并發(fā)核心單元通過它就可以發(fā)送或者接收數(shù)據(jù)進行通訊,這在一定程度上又進一步降低了編程的難度。
channel是一個數(shù)據(jù)類型,主要用來解決go程的同步問題以及協(xié)程之間數(shù)據(jù)共享(數(shù)據(jù)傳遞)的問題。
(1)channle 本質(zhì)上是一個數(shù)據(jù)結(jié)構(gòu)——(隊列),數(shù)據(jù)是先進先出。
(2)具有線程安全機制,多個go程訪問時,不需要枷鎖,也就是說channel本身是線程安全的。
(3)channel是有類型的,如一個string類型的channel只能存放string類型數(shù)據(jù)。
Channel遍歷主要分為3種:
var ch8 = make(chan int, 6) func mm1() { for i := 0; i 10; i++ { ch8 - 8 * i } } func main() { go mm1() for i:=0;i100;i++{ fmt.Print(-ch8, "\t") } }
注:
(1)寫入的次數(shù)與讀取的次數(shù)需要一致(本例是10);
(2)如果讀的次數(shù)多于寫的次數(shù)會發(fā)生:fatal error: all goroutines are asleep - deadlock! ,若 在mm1中對ch8進行關(guān)閉(執(zhí)行 close(ch8) ),多于的次數(shù)讀到的數(shù)據(jù)為0(數(shù)據(jù)默認值)。
(3)讀的次數(shù)少于寫的次數(shù),會讀取出次數(shù)對應(yīng)的內(nèi)容,不會報錯。
if value, ok := -ch; ok == true {
1) 如果寫端沒有寫數(shù)據(jù),也沒有關(guān)閉。-ch; 會阻塞 ---【重點】
2)如果寫端寫數(shù)據(jù), value 保存 -ch 讀到的數(shù)據(jù)。 ok 被設(shè)置為 true
3)如果寫端關(guān)閉。 value 為數(shù)據(jù)類型默認值。ok 被設(shè)置為 false
var ch8 = make(chan int, 6) func mm1() { for i := 0; i 10; i++ { ch8 - 8 * i } close(ch8) } func main() { go mm1() for { if data, ok := -ch8; ok { fmt.Print(data,"\t") } else { break } } }
注:寫完之后一定要關(guān)閉( 執(zhí)行:close(ch8) ),否則會出現(xiàn)以下運行結(jié)果:
for num := range ch { }
var ch8 = make(chan int, 6) func mm1() { for i := 0; i 10; i++ { ch8 - 8 * i } close(ch8) } func main() { go mm1() for { for data := range ch8 { fmt.Print(data,"\t") } break } }
注:寫完之后一定要關(guān)閉( 執(zhí)行:close(ch8) ),否則會出現(xiàn)以下運行結(jié)果:
特別說明:以上實例都是子go程寫,主go程讀。如在子go程中寫,另一個子go程中讀,不管哪種方法,都不會出現(xiàn)以上錯誤問題。(多次實例驗證)
var ch8 = make(chan int, 6) func mm1() { for i := 0; i 10; i++ { ch8 - 8 * i } //close(ch8) } func mm2() { for { for data:=range ch8{ fmt.Print(data,"\t") } } } func main() { go mm1() go mm2() for{ runtime.GC() } }
通過以上驗證,為了保證程序的健壯性,在設(shè)計程序時,最好將channel的讀、寫分別在子go程中進行。寫完數(shù)據(jù)之后,記得關(guān)閉channel。
補充一點:
1、channel不像文件一樣需要經(jīng)常去關(guān)閉,只有當你確實沒有任何發(fā)送數(shù)據(jù)了,或者你想顯式的結(jié)束range循環(huán)之類的,才去關(guān)閉channel;
2、關(guān)閉channel后,無法向channel 再發(fā)送數(shù)據(jù)(引發(fā) panic 錯誤后導致接收立即返回零值);
3、關(guān)閉channel后,可以繼續(xù)從channel接收數(shù)據(jù);
4、對于nil channel,無論收發(fā)都會被阻塞。
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。