Go語言通道之緩沖通道
前文為大傢講解瞭Go語言通道之無緩沖通道
有緩沖的通道相比於無緩沖通道,多瞭一個緩存的功能,如下圖描述的一樣:
從圖上可以明顯看到和無緩沖通道的區別,無緩沖必須兩個Goroutine都進入通道才能進行數據的交換,這個不用,如果數據有,直接就能拿走。
package ChannelDemo import ( "fmt" "math/rand" "sync" "time" ) const ( numberGoroutines = 4 taskLoad = 10 ) var bufferWg sync.WaitGroup func init() { rand.Seed(time.Now().Unix()) } func main() { //創建瞭一個10任務的緩沖通道 tasks := make(chan string, taskLoad) bufferWg.Add(numberGoroutines) //創建4個Goroutine for gr := 1; gr <= numberGoroutines; gr++ { go worker(tasks, gr) } //向緩沖通道中放入數據 for post := 1; post <= taskLoad; post++ { tasks <- fmt.Sprintf("Task : %d", post) } close(tasks) bufferWg.Wait() } func worker(tasks chan string, worker int) { defer bufferWg.Done() for { task, ok := <-tasks if !ok { fmt.Printf("Worker: %d : 結束工作 \n", worker) return } fmt.Printf("Worker: %d : 開始工作 %s\n", worker, task) //隨機處理一下工作的時間 sleep := rand.Int63n(100) time.Sleep(time.Duration(sleep) * time.Millisecond) fmt.Printf("Worker: %d : 完成工作 %s\n", worker, task) } }
運行結果:
Worker: 3 : 開始工作 Task : 4
Worker: 2 : 開始工作 Task : 2
Worker: 1 : 開始工作 Task : 1
Worker: 4 : 開始工作 Task : 3
Worker: 4 : 完成工作 Task : 3
Worker: 4 : 開始工作 Task : 5
Worker: 2 : 完成工作 Task : 2
Worker: 2 : 開始工作 Task : 6
Worker: 3 : 完成工作 Task : 4
Worker: 3 : 開始工作 Task : 7
Worker: 1 : 完成工作 Task : 1
Worker: 1 : 開始工作 Task : 8
Worker: 3 : 完成工作 Task : 7
Worker: 3 : 開始工作 Task : 9
Worker: 1 : 完成工作 Task : 8
Worker: 1 : 開始工作 Task : 10
Worker: 4 : 完成工作 Task : 5
Worker: 4 : 結束工作
Worker: 3 : 完成工作 Task : 9
Worker: 3 : 結束工作
Worker: 2 : 完成工作 Task : 6
Worker: 2 : 結束工作
Worker: 1 : 完成工作 Task : 10
Worker: 1 : 結束工作
因為哪一個worker先從通道中取值有系統自己進行調度的,所以每次運行的結果稍微不同,但是相同的是10個任務被4個協程有條不紊的完成瞭
註意:main中有一句代碼 Close(tasks) 關閉通道的代碼非常重要。當通道關閉後,goroutine 依舊可以從通道接收數據,但是不能再向通道裡發送數據。
能夠從已經關閉的通道接收數據這一點非常重要,因為這允許通道關閉後依舊能取出其中緩沖的全部值,而不會有數據丟失.
總結
無緩沖的通道保證同時交換數據,而有緩沖的通道不做這種保證。
到此這篇關於Go語言通道之緩沖通道的文章就介紹到這瞭。希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。