快捷導(dǎo)航

Golang中的sync.WaitGroup用法實(shí)例

更新時(shí)間：2015年07月04日 10:20:13 投稿：junjie

這篇文章主要介紹了Golang中的sync.WaitGroup用法實(shí)例,WaitGroup的用途,它能夠一直等到所有的goroutine執(zhí)行完成,并且阻塞主線程的執(zhí)行,直到所有的goroutine執(zhí)行完成,需要的朋友可以參考下

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

官方對(duì)它的說明如下：

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個(gè)方法，Add()，Done()，Wait()。

其中Done()是Add(-1)的別名。簡(jiǎn)單的來說，使用Add()添加計(jì)數(shù)，Done()減掉一個(gè)計(jì)數(shù)，計(jì)數(shù)不為0, 阻塞Wait()的運(yùn)行。

例子代碼如下：

同時(shí)開三個(gè)協(xié)程去請(qǐng)求網(wǎng)頁(yè)，等三個(gè)請(qǐ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()

或者下面的測(cè)試代碼

用于測(cè)試給chan發(fā)送 1千萬(wàn)次，并接受1千萬(wàn)次的性能。

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項(xiàng)目中輸出版本信息
這篇文章主要介紹了詳解如何在Go項(xiàng)目中輸出版本信息，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2020-01-01
Go語(yǔ)言中defer語(yǔ)句的用法
這篇文章介紹了Go語(yǔ)言中defer語(yǔ)句的用法，文中通過示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下
2022-07-07
Go 1.22對(duì)net/http包的路由增強(qiáng)功能詳解
Go 1.22 版本對(duì) net/http 包的路由功能進(jìn)行了增強(qiáng),引入了方法匹配（method matching）和通配符（wildcards）兩項(xiàng)新功能,本文將給大家詳細(xì)的介紹一下Go 1.22對(duì)net/http包的路由增強(qiáng)功能,需要的朋友可以參考下
2024-02-02
使用Go語(yǔ)言與MQTT進(jìn)行通信的示例代碼
本文介紹了如何使用 Go 編程語(yǔ)言與 MQTT（Message Queuing Telemetry Transport）進(jìn)行通信,MQTT 是一種輕量級(jí)的消息傳輸協(xié)議,廣泛應(yīng)用于物聯(lián)網(wǎng)和實(shí)時(shí)通信場(chǎng)景,通過本文的指導(dǎo),您將學(xué)習(xí)如何使用 Go 語(yǔ)言創(chuàng)建 MQTT 客戶端,進(jìn)行消息的發(fā)布和訂閱,需要的朋友可以參考下
2023-12-12
詳解Golang開啟http服務(wù)的三種方式
這篇文章主要介紹了詳解Golang開啟http服務(wù)的三種方式，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2020-06-06
go nil處理如何正確返回nil的error
這篇文章主要為大家介紹了go中的nil處理,如何正確返回nil的error實(shí)例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
2023-10-10
go語(yǔ)言使用中提示%!(NOVERB)的解決方案
o語(yǔ)言的設(shè)計(jì)目標(biāo)是提供一種簡(jiǎn)單易用的編程語(yǔ)言,同時(shí)保持高效性和可擴(kuò)展性,它支持垃圾回收機(jī)制,具有強(qiáng)大的并發(fā)編程能力,可以輕松處理大規(guī)模的并發(fā)任務(wù),Go語(yǔ)言還擁有豐富的標(biāo)準(zhǔn)庫(kù)和活躍的開發(fā)社區(qū),使得開發(fā)者能夠快速構(gòu)建出高質(zhì)量的應(yīng)用程序,需要的朋友可以參考下
2023-10-10
goland 搭建 gin 框架的步驟詳解
這篇文章主要介紹了goland 搭建 gin 框架的相關(guān)知識(shí)，本文通過圖文并茂的形式給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
2020-11-11
golang使用excelize庫(kù)操作excel文件的方法詳解
Excelize是Go語(yǔ)言編寫的用于操作Office Excel文檔基礎(chǔ)庫(kù),基于ECMA-376，ISO/IEC 29500國(guó)際標(biāo)準(zhǔn),下面這篇文章主要給大家介紹了關(guān)于golang使用excelize庫(kù)操作excel文件的相關(guān)資料,需要的朋友可以參考下
2022-11-11
go HTTP2 的頭部壓縮算法hpack實(shí)現(xiàn)詳解
這篇文章主要為大家介紹了go HTTP2 的頭部壓縮算法hpack實(shí)現(xiàn)詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
2022-10-10