Golang中的sync.WaitGroup用法實例
更新時間：2015年07月04日 10:20:13 投稿：junjie
這篇文章主要介紹了Golang中的sync.WaitGroup用法實例,WaitGroup的用途,它能夠一直等到所有的goroutine執(zhí)行完成,并且阻塞主線程的執(zhí)行,直到所有的goroutine執(zhí)行完成,需要的朋友可以參考下
WaitGroup的用途：它能夠一直等到所有的goroutine執(zhí)行完成，并且阻塞主線程的執(zhí)行，直到所有的goroutine執(zhí)行完成。
官方對它的說明如下：
A WaitGroup waits for a collection of goroutines to finish. The main goroutine calls Add to set the number of goroutines to wait for. Then each of the goroutines runs and calls Done when finished. At the same time, Wait can be used to block until all goroutines have finished.
sync.WaitGroup只有3個方法，Add()，Done()，Wait()。
其中Done()是Add(-1)的別名。簡單的來說，使用Add()添加計數(shù)，Done()減掉一個計數(shù)，計數(shù)不為0, 阻塞Wait()的運行。
例子代碼如下：
同時開三個協(xié)程去請求網(wǎng)頁， 等三個請求都完成后才繼續(xù) Wait 之后的工作。
var wg sync.WaitGroup
var urls = []string{
"http://www.golang.org/",
"http://www.google.com/",
"http://www.somestupidname.com/",
}
for _, url := range urls {
// Increment the WaitGroup counter.
wg.Add(1)
// Launch a goroutine to fetch the URL.
go func(url string) {
// Decrement the counter when the goroutine completes.
defer wg.Done()
// Fetch the URL.
http.Get(url)
}(url)
}
// Wait for all HTTP fetches to complete.
wg.Wait()
或者下面的測試代碼
用于測試 給chan發(fā)送 1千萬次，并接受1千萬次的性能。
package main
import (
"fmt"
"sync"
"time"
)
const (
num = 10000000
)
func main() {
TestFunc("testchan", TestChan)
}
func TestFunc(name string, f func()) {
st := time.Now().UnixNano()
f()
fmt.Printf("task %s cost %d \r\n", name, (time.Now().UnixNano()-st)/int64(time.Millisecond))
}
func TestChan() {
var wg sync.WaitGroup
c := make(chan string)
wg.Add(1)
go func() {
for _ = range c {
}
wg.Done()
}()
for i := 0; i < num; i++ {
c <- "123"
}
close(c)
wg.Wait()
}
相關(guān)文章
這篇文章主要介紹了詳解如何在Go項目中輸出版本信息，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習或者工作具有一定的參考學(xué)習價值，需要的朋友們下面隨著小編來一起學(xué)習學(xué)習吧2020-01-01
這篇文章介紹了Go語言中defer語句的用法，文中通過示例代碼介紹的非常詳細。對大家的學(xué)習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-07-07
Go 1.22 版本對 net/http 包的路由功能進行了增強,引入了方法匹配（method matching）和通配符（wildcards）兩項新功能,本文將給大家詳細的介紹一下Go 1.22對net/http包的路由增強功能,需要的朋友可以參考下2024-02-02
本文介紹了如何使用 Go 編程語言與 MQTT（Message Queuing Telemetry Transport）進行通信,MQTT 是一種輕量級的消息傳輸協(xié)議,廣泛應(yīng)用于物聯(lián)網(wǎng)和實時通信場景,通過本文的指導(dǎo),您將學(xué)習如何使用 Go 語言創(chuàng)建 MQTT 客戶端,進行消息的發(fā)布和訂閱,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了詳解Golang開啟http服務(wù)的三種方式，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習或者工作具有一定的參考學(xué)習價值，需要的朋友們下面隨著小編來一起學(xué)習學(xué)習吧2020-06-06
這篇文章主要為大家介紹了go中的nil處理,如何正確返回nil的error實例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10
o語言的設(shè)計目標是提供一種簡單易用的編程語言,同時保持高效性和可擴展性,它支持垃圾回收機制,具有強大的并發(fā)編程能力,可以輕松處理大規(guī)模的并發(fā)任務(wù),Go語言還擁有豐富的標準庫和活躍的開發(fā)社區(qū),使得開發(fā)者能夠快速構(gòu)建出高質(zhì)量的應(yīng)用程序,需要的朋友可以參考下2023-10-10
這篇文章主要介紹了goland 搭建 gin 框架的相關(guān)知識，本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學(xué)習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-11-11
golang使用excelize庫操作excel文件的方法詳解
Excelize是Go語言編寫的用于操作Office Excel文檔基礎(chǔ)庫,基于ECMA-376，ISO/IEC 29500國際標準,下面這篇文章主要給大家介紹了關(guān)于golang使用excelize庫操作excel文件的相關(guān)資料,需要的朋友可以參考下2022-11-11
go HTTP2 的頭部壓縮算法hpack實現(xiàn)詳解
這篇文章主要為大家介紹了go HTTP2 的頭部壓縮算法hpack實現(xiàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-10-10