遇到golang channel 的一個問題：發(fā)現(xiàn)go 協(xié)程讀取channel 數(shù)據(jù) 并沒有按照預(yù)期進行協(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 時，在沒有協(xié)程取出數(shù)據(jù)的情況下， 會阻塞當(dāng)前協(xié)程的運行。ch <- 后面的代碼就不會再運行，直到channel 的數(shù)據(jù)被接收，當(dāng)前協(xié)程才會繼續(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é)程將會阻塞，等待數(shù)據(jù)被讀取
fmt.Println("ch 數(shù)據(jù)被消費，主協(xié)程退出")

有緩沖區(qū)channel

channel 的緩沖區(qū)為1，向channel 發(fā)送第一個數(shù)據(jù)，主協(xié)程不會退出。發(fā)送第二個時候，緩沖區(qū)已經(jīng)滿了， 此時阻塞主協(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é)程不會阻塞，等待數(shù)據(jù)被讀取
fmt.Println("第二次發(fā)送數(shù)據(jù)到channel， 即將阻塞")
ch <-1  // 第二次發(fā)送數(shù)據(jù)到channel, 在數(shù)據(jù)沒有被讀取之前，因為緩沖區(qū)滿了， 所以會阻塞主協(xié)程。
fmt.Println("ch 數(shù)據(jù)被消費，主協(xié)程退出")

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

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