說起 Go 協程的調度，如果你了解 Go 調度器以及其實現的 G/P/M 模型，當然有助于應用的開發。但是在應用層面上，這些底層的調度原理并不會幫你太多，實現 Go 協程的精準調度得完全靠自己。

問題

例如，實際應用中我們要解決的問題是這樣的。那么，我們該如何實現調度的精準控制呢？

實現

簡單的協程控制，很多人都會使用 sync.WaitGroup 進行多協程的控制。但是 sync.WaitGroup 面對圖示的調度控制就顯得無能為力了。

上圖的協程調度看似復雜，如果仔細分析一下，就會發現單個協程的啟動需要等待依賴協程完成才能開始。所以，問題的關鍵是實現協程間的前置依賴。

那么，這樣一個前置依賴該如何實現呢？這里直接貼出我的方案，你也可以想想你要如何實現。

package?eventimport?(?"sync"?"sync/atomic")type?Event?struct?{?fired?int32?c?????chan?struct{}?once??sync.Once}func?New()?*Event?{?return?&Event{c:?make(chan?struct{})}}func?(ev?*Event)?Fire()?int32?{?atomic.AddInt32(&ev.fired,?1)?ev.once.Do(func()?{??close(ev.c)?})?return?ev.fired}func?(ev?*Event)?Done()??0}

這樣一個簡單的事件觸發器就可以來模擬協程前置依賴。例如，圖示中的B1的啟動依賴于A1與C1，那么我們的實現代碼就可以這樣實現:

package?mainimport?(????"github.com/x-mod/event"?//Event?開源項目在這里)func?main(){????//前置依賴????a1?:=?event.New()????b1?:=?event.New()????c1?:=?event.New()????//A1?協程????go?func(){????????defer?a1.Fire()????????//?A1?LOGIC?...????}????//B1?協程????go?func(){????????defer?b1.Fire()????????????????//?等待前置依賴完成????????

項目地址：https://github.com/x-mod/event

與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的go 怎么等待所有的协程完成_Go 编程：如何实现协程调度的精准控制的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。