遇到golang channel 的一個(gè)問題:發(fā)現(xiàn)go 協(xié)程讀取channel 數(shù)據(jù) 并沒有按照預(yù)期進(jìn)行協(xié)作執(zhí)行。
經(jīng)過查資料:
使用channel 操作不當(dāng)導(dǎo)致,channel分 有緩沖區(qū) 和 無緩沖區(qū) , 以下是兩者的區(qū)別。
無緩沖區(qū)channel
用make(chan int) 創(chuàng)建的chan, 是無緩沖區(qū)的, send 數(shù)據(jù)到chan 時(shí),在沒有協(xié)程取出數(shù)據(jù)的情況下, 會(huì)阻塞當(dāng)前協(xié)程的運(yùn)行。ch - 后面的代碼就不會(huì)再運(yùn)行,直到channel 的數(shù)據(jù)被接收,當(dāng)前協(xié)程才會(huì)繼續(xù)往下執(zhí)行。
ch := make(chan int) // 創(chuàng)建無緩沖channel
go func() {
fmt.Println("time sleep 5 second...")
time.Sleep(5 * time.Second)
-ch
}()
h
fmt.Println("即將阻塞...")
ch -1 // 協(xié)程將會(huì)阻塞,等待數(shù)據(jù)被讀取
fmt.Println("ch 數(shù)據(jù)被消費(fèi),主協(xié)程退出")
有緩沖區(qū)channel
channel 的緩沖區(qū)為1,向channel 發(fā)送第一個(gè)數(shù)據(jù),主協(xié)程不會(huì)退出。發(fā)送第二個(gè)時(shí)候,緩沖區(qū)已經(jīng)滿了, 此時(shí)阻塞主協(xié)程。
ch := make(chan int, 1) // 創(chuàng)建有緩沖channel
go func() {
fmt.Println("time sleep 5 second...")
time.Sleep(5 * time.Second)
-ch
}()
ch -1 // 協(xié)程不會(huì)阻塞,等待數(shù)據(jù)被讀取
fmt.Println("第二次發(fā)送數(shù)據(jù)到channel, 即將阻塞")
ch -1 // 第二次發(fā)送數(shù)據(jù)到channel, 在數(shù)據(jù)沒有被讀取之前,因?yàn)榫彌_區(qū)滿了, 所以會(huì)阻塞主協(xié)程。
fmt.Println("ch 數(shù)據(jù)被消費(fèi),主協(xié)程退出")
總結(jié): 在創(chuàng)建channel的時(shí)候, 要注意是否需要緩沖區(qū)。有緩沖區(qū)時(shí):在不超過緩沖區(qū)大小時(shí),不會(huì)出現(xiàn) 發(fā)送方阻塞. 無緩沖區(qū)時(shí): 只要channel 數(shù)據(jù)沒有被拿走,始終會(huì)阻塞發(fā)送方。
以上所述是小編給大家介紹的詳解go語言 make(chan int, 1) 和 make (chan int) 的區(qū)別,希望對(duì)大家有所幫助,如果大家有任何疑問請(qǐng)給我留言,小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
如果你覺得本文對(duì)你有幫助,歡迎轉(zhuǎn)載,煩請(qǐng)注明出處,謝謝!
您可能感興趣的文章:- 深入講解Go語言中函數(shù)new與make的使用和區(qū)別
- GO語言make()分配用法實(shí)例
- Go語言中new()和 make()的區(qū)別詳解