Go語(yǔ)言的Channel遍歷方法詳解
先來(lái)看看基本的定義:
channel是Go語(yǔ)言中的一個(gè)核心類型,可以把它看成管道。并發(fā)核心單元通過(guò)它就可以發(fā)送或者接收數(shù)據(jù)進(jìn)行通訊,這在一定程度上又進(jìn)一步降低了編程的難度。
channel是一個(gè)數(shù)據(jù)類型,主要用來(lái)解決go程的同步問(wèn)題以及協(xié)程之間數(shù)據(jù)共享(數(shù)據(jù)傳遞)的問(wèn)題。
(1)channle 本質(zhì)上是一個(gè)數(shù)據(jù)結(jié)構(gòu)——(隊(duì)列),數(shù)據(jù)是先進(jìn)先出。
(2)具有線程安全機(jī)制,多個(gè)go程訪問(wèn)時(shí),不需要枷鎖,也就是說(shuō)channel本身是線程安全的。
(3)channel是有類型的,如一個(gè)string類型的channel只能存放string類型數(shù)據(jù)。
Channel遍歷主要分為3種:
1)簡(jiǎn)單的讀 data:=<-ch (如果讀多次,需要用循環(huán))
var ch8 = make(chan int, 6) func mm1() { for i := 0; i < 10; i++ { ch8 <- 8 * i } } func main() { go mm1() for i:=0;i<100;i++{ fmt.Print(<-ch8, "\t") } }
注:
(1)寫入的次數(shù)與讀取的次數(shù)需要一致(本例是10);
(2)如果讀的次數(shù)多于寫的次數(shù)會(huì)發(fā)生:fatal error: all goroutines are asleep - deadlock! ,若 在mm1中對(duì)ch8進(jìn)行關(guān)閉(執(zhí)行 close(ch8) ),多于的次數(shù)讀到的數(shù)據(jù)為0(數(shù)據(jù)默認(rèn)值)。
(3)讀的次數(shù)少于寫的次數(shù),會(huì)讀取出次數(shù)對(duì)應(yīng)的內(nèi)容,不會(huì)報(bào)錯(cuò)。
2)斷言方式
if value, ok := <-ch; ok == true {
1) 如果寫端沒(méi)有寫數(shù)據(jù),也沒(méi)有關(guān)閉。<-ch; 會(huì)阻塞 ---【重點(diǎn)】
2)如果寫端寫數(shù)據(jù), value 保存 <-ch 讀到的數(shù)據(jù)。 ok 被設(shè)置為 true
3)如果寫端關(guān)閉。 value 為數(shù)據(jù)類型默認(rèn)值。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) ),否則會(huì)出現(xiàn)以下運(yùn)行結(jié)果:
3)通過(guò)range方法
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) ),否則會(huì)出現(xiàn)以下運(yùn)行結(jié)果:
特別說(shuō)明:以上實(shí)例都是子go程寫,主go程讀。如在子go程中寫,另一個(gè)子go程中讀,不管哪種方法,都不會(huì)出現(xiàn)以上錯(cuò)誤問(wèn)題。(多次實(shí)例驗(yà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() } }
總結(jié):
通過(guò)以上驗(yàn)證,為了保證程序的健壯性,在設(shè)計(jì)程序時(shí),最好將channel的讀、寫分別在子go程中進(jìn)行。寫完數(shù)據(jù)之后,記得關(guān)閉channel。
補(bǔ)充一點(diǎn):
1、channel不像文件一樣需要經(jīng)常去關(guān)閉,只有當(dāng)你確實(shí)沒(méi)有任何發(fā)送數(shù)據(jù)了,或者你想顯式的結(jié)束range循環(huán)之類的,才去關(guān)閉channel;
2、關(guān)閉channel后,無(wú)法向channel 再發(fā)送數(shù)據(jù)(引發(fā) panic 錯(cuò)誤后導(dǎo)致接收立即返回零值);
3、關(guān)閉channel后,可以繼續(xù)從channel接收數(shù)據(jù);
4、對(duì)于nil channel,無(wú)論收發(fā)都會(huì)被阻塞。
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
相關(guān)文章
golang rate令牌桶源碼分析實(shí)現(xiàn)方式
這篇文章主要介紹了golang rate令牌桶源碼分析實(shí)現(xiàn)方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-07-07Golang?WebSocket創(chuàng)建單獨(dú)會(huì)話詳細(xì)實(shí)例
這篇文章主要給大家介紹了關(guān)于Golang?WebSocket創(chuàng)建單獨(dú)會(huì)話的相關(guān)資料,WebSocket 協(xié)議主要為了解決基于 HTTP/1.x 的 Web 應(yīng)用無(wú)法實(shí)現(xiàn)服務(wù)端向客戶端主動(dòng)推送的問(wèn)題,文中通過(guò)代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-11-11Go語(yǔ)言實(shí)現(xiàn)的最簡(jiǎn)單數(shù)獨(dú)解法
前面給大家介紹過(guò)使用javascript實(shí)現(xiàn)的簡(jiǎn)單的數(shù)獨(dú)解法,小伙伴們都非常喜歡,今天我們?cè)賮?lái)分享一則go語(yǔ)言實(shí)現(xiàn)的簡(jiǎn)單的數(shù)獨(dú)解法,有需要的小伙伴來(lái)參考下。2015-03-03Golang并發(fā)發(fā)送HTTP請(qǐng)求的各種方法
在 Golang 領(lǐng)域,并發(fā)發(fā)送 HTTP 請(qǐng)求是優(yōu)化 Web 應(yīng)用程序的一項(xiàng)重要技能,本文探討了實(shí)現(xiàn)此目的的各種方法,從基本的 goroutine 到涉及通道和sync.WaitGroup 的高級(jí)技術(shù),需要的朋友可以參考下2024-02-02GoFrame?gmap遍歷hashmap?listmap?treemap使用技巧
這篇文章主要為大家介紹了GoFrame?gmap遍歷hashmap?listmap?treemap使用技巧的示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06Golang程序中使用Prometheus的client_golang庫(kù)
這篇文章主要介紹了Golang程序中使用Prometheus的client_golang庫(kù),Prometheus 是一個(gè)開源的監(jiān)控和警報(bào)工具包,用于收集和處理應(yīng)用程序和系統(tǒng)的指標(biāo)數(shù)據(jù)。Prometheus 提供了多種客戶端庫(kù),可以輕松地集成到各種編程語(yǔ)言中2023-04-04Go語(yǔ)言基礎(chǔ)函數(shù)包的使用學(xué)習(xí)
本文通過(guò)一個(gè)實(shí)現(xiàn)加減乘除運(yùn)算的小程序來(lái)介紹go函數(shù)的使用,以及使用函數(shù)的注意事項(xiàng),并引出了對(duì)包的了解和使用,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-05-05