3種優雅的Go channel用法

寫go的人應該都聽過rob pike的這句話

do not communicate by sharing memory; instead, share memory by communicating.

相信很多朋友和我一樣，在實際應用中總感覺不到好處，為了用channel而用。但以我的切身體會來說，這是寫**時碰到的場景不複雜、對channel不熟悉導致的，所以希望這篇文章能給大家帶來點新思路，對golang優雅的channel有更深的認識：）

資料的輸出有時候需要做扇出／入（fan in／out），但是在函式中呼叫常常得修改介面，而且上下游對於資料的依賴程度非常高，所以一般使用通過channel進行fan in／out，這樣就可以輕易實現類似於shell裡的管道。

func fanin(input1, input2 <-chan string) <-chan string 
}}()
return c
}

兩個goroutine之間同步狀態，例如a goroutine需要讓b goroutine退出，一般做法如下：

func main() 
quit <- true // 沒辦法等待b的退出只能sleep
fmt.println("main quit")
}func b() 
}}/*
output:12
3main quit
*/

可是了main函式沒辦法等待b合適地退出，所以b quit 沒辦法列印，程式直接退出了。然而，chan是go裡的第一物件，所以可以把chan傳入chan中，所以上面的**可以把quit 定義為chan chan bool，以此控制兩個goroutine的同步

func main() 
wait := make(chan bool)
quit <- wait
<-wait //這樣就可以等待b的退出了
fmt.println("main quit")
}func b() 
}}/* output12
3b quit
main quit
*/

在現實生活中，如果你要找美國**聊天，你會怎麼做？第一步打**給在美國的朋友，然後他們也會發動自己的關係網，再找可能認識美國**的人，以此類推，直到找到為止。這在kadmelia分布式系統中也是一樣的，如果需要獲取目標id資訊，那麼就不停地查詢，被查詢節點就算沒有相關資訊，也會返回它覺得最近節點，直到找到id或者等待超時。好了，這個要用go來實現怎麼做呢？

func recursivecall(ctx context.context, id byte, initialnodes *node) //已見過的節點記錄
request := make(chan *node, 3) //設定請求節點channel
// 輸入初始節點
go func() 
}()out:
for 
// 在新的請求，超時和上層取消請求中select
select 
addnode(rn)
// 將新的節點送入channel
request <- rn}}
}}()
case <-time.after(500 * time.millisecond):
break out // break至外層，否則僅僅是跳至loop外
case <-ctx.done():
break out
}	}return
}

這時的buffered channel類似於乙個區域性queue，對需要的節點進行處理，但這段**的精妙之處在於，這裡的block操作是select的，隨時可以取消，而不是要等待或者對queue的長度有認識。

你對這三種channel的用法有什麼疑問，歡迎討論╮(╯▽╰)╭

3種優雅的Go channel用法

用Vim優雅的編輯

優雅的用英語罵人

用Markdown優雅的寫文章

3種優雅的Go channel用法

用Vim優雅的編輯

優雅的用英語罵人

用Markdown優雅的寫文章

相關推薦