Go緩沖channel和非緩沖channel的區(qū)別說明
在看本篇文章前我們需要了解阻塞的概念
在執(zhí)行過程中暫停，以等待某個條件的觸發(fā) ，我們就稱之為阻塞
在Go中我們make一個channel有兩種方式，分別是有緩沖的和沒緩沖的
緩沖channel 即 buffer channel 創(chuàng)建方式為 make(chan TYPE,SIZE)
如 make(chan int,3) 就是創(chuàng)建一個int類型，緩沖大小為3的 channel
非緩沖channel 即 unbuffer channel 創(chuàng)建方式為 make(chan TYPE)
如 make(chan int) 就是創(chuàng)建一個int類型的非緩沖channel
非緩沖channel 和 緩沖channel 的區(qū)別
非緩沖 channel，channel 發(fā)送和接收動作是同時發(fā)生的
例如 ch := make(chan int) ，如果沒 goroutine 讀取接收者<-ch ，那么發(fā)送者ch<- 就會一直阻塞
緩沖 channel 類似一個隊列，只有隊列滿了才可能發(fā)送阻塞
代碼演示
非緩沖 channel
package main
import (
"fmt"
"time"
)
func loop(ch chan int) {
for {
select {
case i := <-ch:
fmt.Println("this value of unbuffer channel", i)
}
}
}
func main() {
ch := make(chan int)
ch <- 1
go loop(ch)
time.Sleep(1 * time.Millisecond)
}
這里會報錯 fatal error: all goroutines are asleep - deadlock! 就是因為 ch<-1 發(fā)送了，但是同時沒有接收者，所以就發(fā)生了阻塞
但如果我們把 ch <- 1 放到 go loop(ch) 下面，程序就會正常運行
緩沖 channel
的阻塞只會發(fā)生在 channel 的緩沖使用完的情況下
package main
import (
"fmt"
"time"
)
func loop(ch chan int) {
for {
select {
case i := <-ch:
fmt.Println("this value of unbuffer channel", i)
}
}
}
func main() {
ch := make(chan int,3)
ch <- 1
ch <- 2
ch <- 3
ch <- 4
go loop(ch)
time.Sleep(1 * time.Millisecond)
}
這里也會報 fatal error: all goroutines are asleep - deadlock! ，這是因為 channel 的大小為 3 ，而我們要往里面塞 4 個數據，所以就會阻塞住
解決的辦法有兩個
把 channel 開大一點，這是最簡單的方法，也是最暴力的
把 channel 的信息發(fā)送者 ch <- 1 這些代碼移動到 go loop(ch) 下面 ，讓 channel 實時消費就不會導致阻塞了
補充：3種優(yōu)雅的Go channel用法
寫Go的人應該都聽過Rob Pike的這句話
Do not communicate by sharing memory; instead, share memory by communicating.
相信很多朋友和我一樣，在實際應用中總感覺不到好處，為了用channel而用。但以我的切身體會來說，這是寫代碼時碰到的場景不復雜、對channel不熟悉導致的，所以希望這篇文章能給大家?guī)睃c新思路，對Golang優(yōu)雅的channel有更深的認識 ：）
Fan In/Out
數據的輸出有時候需要做扇出／入（Fan In／Out），但是在函數中調用常常得修改接口，而且上下游對于數據的依賴程度非常高，所以一般使用通過channel進行Fan In／Out，這樣就可以輕易實現類似于shell里的管道。
func fanIn(input1, input2 <-chan string) <-chan string {
c := make(chan string)
go func() {
for {
select {
case s := <-input1: c <- s
case s := <-input2: c <- s
}
}
}()
return c
}
同步Goroutine
兩個goroutine之間同步狀態(tài)，例如A goroutine需要讓B goroutine退出，一般做法如下：
func main() {
g = make(chan int)
quit = make(chan bool)
go B()
for i := 0; i < 3; i++ {
g <- i
}
quit <- true // 沒辦法等待B的退出只能Sleep
fmt.Println("Main quit")
}
func B() {
for {
select {
case i := <-g:
fmt.Println(i + 1)
case <-quit:
fmt.Println("B quit")
return
}
}
}
/*
Output:
1
2
3
Main quit
*/
可是了main函數沒辦法等待B合適地退出，所以B quit 沒辦法打印，程序直接退出了。
然而，chan是Go里的第一對象，所以可以把chan傳入chan中，所以上面的代碼可以把quit 定義為chan chan bool，以此控制兩個goroutine的同步
func main() {
g = make(chan int)
quit = make(chan chan bool)
go B()
for i := 0; i < 5; i++ {
g <- i
}
wait := make(chan bool)
quit <- wait
<-wait //這樣就可以等待B的退出了
fmt.Println("Main Quit")
}
func B() {
for {
select {
case i := <-g:
fmt.Println(i + 1)
case c := <-quit:
c <- true
fmt.Println("B Quit")
return
}
}
}
/* Output
1
2
3
B Quit
Main Quit
*/
分布式遞歸調用
在現實生活中，如果你要找美國總統聊天，你會怎么做？
第一步打電話給在美國的朋友，然后他們也會發(fā)動自己的關系網，再找可能認識美國總統的人，以此類推，直到找到為止。
這在Kadmelia分布式系統中也是一樣的，如果需要獲取目標ID信息，那么就不停地查詢，被查詢節(jié)點就算沒有相關信息，也會返回它覺得最近節(jié)點，直到找到ID或者等待超時。
好了，這個要用Go來實現怎么做呢？
func recursiveCall(ctx context.Context, id []byte, initialNodes []*node){
seen := map[string]*node{} //已見過的節(jié)點記錄
request := make(chan *node, 3) //設置請求節(jié)點channel
// 輸入初始節(jié)點
go func() {
for _, n := range initialNodes {
request <- n
}
}()
OUT:
for {
//循環(huán)直到找到數據
if data != nil {
return
}
// 在新的請求，超時和上層取消請求中select
select {
case n := <-request:
go func() {
// 發(fā)送新的請求
response := s.sendQuery(ctx, n, MethodFindValue, id)
select {
case <-ctx.Done():
case msg :=<-response:
seen[responseToNode(response)] = n //更新已見過的節(jié)點信息
// 加載新的節(jié)點
for _, rn := range LoadNodeInfoFromByte(msg[PayLoadStart:]) {
mu.Lock()
_, ok := seen[rn.HexID()]
mu.Unlock()
// 見過了，跳過這個節(jié)點
if ok {
continue
}
AddNode(rn)
// 將新的節(jié)點送入channel
request <- rn
}
}
}
}()
case <-time.After(500 * time.Millisecond):
break OUT // break至外層，否則僅僅是跳至loop外
case <-ctx.Done():
break OUT
}
}
return
}
這時的buffered channel類似于一個局部queue，對需要的節(jié)點進行處理，但這段代碼的精妙之處在于，這里的block操作是select的，隨時可以取消，而不是要等待或者對queue的長度有認識。
以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方，望不吝賜教。
相關文章
服務端經常需要返回一個列表，里面包含很多用戶數據，常規(guī)做法當然是遍歷然后讀緩存。使用Go語言后，可以并發(fā)獲取，極大提升效率，本文就來聊聊具體的實現方法，希望對大家有所幫助2023-02-02
Go?實現?WebSockets之創(chuàng)建?WebSockets
這篇文章主要介紹了Go?實現?WebSockets之創(chuàng)建?WebSockets，文章主要探索?WebSockets，并簡要介紹了它們的工作原理，并仔細研究了全雙工通信，想了解更多相關內容的小伙伴可以參考一下2022-04-04
go-mock是專門為go語言開發(fā)的mock庫，該庫使用方式簡單，支持自動生成代碼，這篇文章主要介紹了用gomock進行mock測試的方法示例，感興趣的小伙伴們可以參考一下2018-11-11
這篇文章主要介紹了GoPath模式和GoMoudle模式的相愛相殺,本文通過實例圖文相結合給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2021-03-03
這篇文章主要介紹了基于golang的輕量級工作流框架Fastflow,fastflow 執(zhí)行任務的過程會涉及到幾個概念：Dag, Task, Action, DagInstance，本文給大家分享完整流程，需要的朋友可以參考下2022-05-05
本文主要介紹了golang chan的使用，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2022-06-06
本文給大家分享的是使用go語言實現的抓取高清美女圖片的代碼，原理非常簡單，這里就不多廢話了，主要是看到很多小伙伴使用python實現的，心血來潮就用go寫了下，推薦給大家。2015-03-03
Go開發(fā)go-optioner工具實現輕松生成函數選項模式代碼
go-optioner?是一個在?Go?代碼中生成函數選項模式代碼的工具，可以根據給定的結構定義自動生成相應的選項代碼，下面就來聊聊go-optioner是如何使用的吧2023-07-07
這篇文章主要介紹了淺談golang并發(fā)操作變量安全的問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
這篇文章主要介紹了Golang中Bit數組的實現方式，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04