遇到golang channel 的一個(gè)問(wèn)題：發(fā)現(xiàn)go 協(xié)程讀取channel 數(shù)據(jù) 并沒(méi)有按照預(yù)期進(jìn)行協(xié)作執(zhí)行。

經(jīng)過(guò)查資料：

使用channel 操作不當(dāng)導(dǎo)致,channel分 有緩沖區(qū) 和 無(wú)緩沖區(qū) , 以下是兩者的區(qū)別。

無(wú)緩沖區(qū)channel

用make(chan int) 創(chuàng)建的chan, 是無(wú)緩沖區(qū)的, send 數(shù)據(jù)到chan 時(shí)，在沒(méi)有協(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)建無(wú)緩沖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ù)沒(méi)有被讀取之前，因?yàn)榫彌_區(qū)滿了， 所以會(huì)阻塞主協(xié)程。
fmt.Println("ch 數(shù)據(jù)被消費(fèi)，主協(xié)程退出")

總結(jié)： 在創(chuàng)建channel的時(shí)候， 要注意是否需要緩沖區(qū)。有緩沖區(qū)時(shí)：在不超過(guò)緩沖區(qū)大小時(shí)，不會(huì)出現(xiàn) 發(fā)送方阻塞. 無(wú)緩沖區(qū)時(shí): 只要channel 數(shù)據(jù)沒(méi)有被拿走，始終會(huì)阻塞發(fā)送方。

以上所述是小編給大家介紹的詳解go語(yǔ)言 make(chan int, 1) 和 make (chan int) 的區(qū)別，希望對(duì)大家有所幫助，如果大家有任何疑問(wèn)請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持！
如果你覺(jué)得本文對(duì)你有幫助，歡迎轉(zhuǎn)載，煩請(qǐng)注明出處，謝謝！