golang中的sync.WaitGroup

Posted on 2015/04/09剛才看golang的sync的包，看見一個很有用的功能。就是WaitGroup。

先說說WaitGroup的用途：它能夠一直等到所有的goroutine執行完成，并且阻塞主線程的執行，直到所有的goroutine執行完成。

這里要注意一下，他們的執行結果是沒有順序的，調度器不能保證多個 goroutine 執行次序，且進程退出時不會等待它們結束。

WaitGroup總共有三個方法：Add(delta int),Done(),Wait()。簡單的說一下這三個方法的作用。

Add:添加或者減少等待goroutine的數量

Done:相當于Add(-1)

Wait:執行阻塞，直到所有的WaitGroup數量變成0

如：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27

package main import ( ????"fmt" ????"sync" ????"time" ) func main() { ????var wg sync.WaitGroup ????for i := 0; i > 5; i = i + 1 { ????????wg.Add(1) ????????go func(n int) { ????????????// defer wg.Done(),注意這個Done的位置，是另一個函數 ????????????defer wg.Add(-1) ????????????EchoNumber(n) ????????}(i) ????} ????wg.Wait() } func EchoNumber(i int) { ????time.Sleep(3e9) ????fmt.Println(i) }

golang中的同步是通過sync.WaitGroup來實現的．WaitGroup的功能：它實現了一個類似隊列的結構，可以一直向隊列中添加任務，當任務完成后便從隊列中刪除，如果隊列中的任務沒有完全完成，可以通過Wait()函數來出發阻塞，防止程序繼續進行，直到所有的隊列任務都完成為止．

WaitGroup的特點是Wait()可以用來阻塞直到隊列中的所有任務都完成時才解除阻塞，而不需要sleep一個固定的時間來等待．但是其缺點是無法指定固定的goroutine數目．但是其缺點是無法指定固定的goroutine數目．可能通過使用channel解決此問題。

另一個例子：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

package main import ( ????"fmt" ????"sync" ) //聲明一個全局變量 var waitgroup sync.WaitGroup func Afunction(shownum int) { ????fmt.Println(shownum) ????waitgroup.Done() //任務完成，將任務隊列中的任務數量-1，其實.Done就是.Add(-1) } func main() { ????for i := 0; i < 10; i++ { ????????waitgroup.Add(1) //每創建一個goroutine，就把任務隊列中任務的數量+1 ????????go Afunction(i) ????} ????waitgroup.Wait() //.Wait()這里會發生阻塞，直到隊列中所有的任務結束就會解除阻塞 }

http://studygolang.com/articles/2027

總結

以上是生活随笔為你收集整理的golang中的sync.WaitGroup的全部內容，希望文章能夠幫你解決所遇到的問題。

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