溫馨提示×

Golang中的并發控制和Go WaitGroup

小云
128
2023-10-08 03:47:56
欄目: 編程語言

在Golang中,可以使用并發控制來管理多個goroutine的執行。其中,一個常見的并發控制機制是使用sync.WaitGroup。

sync.WaitGroup是Golang標準庫中的一個結構體,用于等待一組goroutine執行完成。它提供了以下三個方法:

  1. Add(delta int):增加等待的goroutine數量,delta為正值表示增加,負值表示減少。

  2. Done():表示一個goroutine已經執行完成,減少等待的goroutine數量。

  3. Wait():阻塞,直到所有等待的goroutine執行完成。

下面是一個使用sync.WaitGroup的示例:

package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
for i := 0; i < 5; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
fmt.Println("goroutine", i, "done")
}(i)
}
wg.Wait()
fmt.Println("all goroutines done")
}

在上面的示例中,首先創建了一個sync.WaitGroup實例wg。然后,使用Add方法增加了5個等待的goroutine數量。接著,使用go關鍵字創建了5個goroutine,每個goroutine打印了自己的id并調用Done方法表示執行完成。最后,調用wg.Wait()方法阻塞,直到所有goroutine執行完成。

需要注意的是,每個goroutine中必須調用Done方法來通知sync.WaitGroup已完成。否則,Wait方法會一直阻塞。

使用sync.WaitGroup可以方便地管理多個goroutine的并發執行,等待它們全部執行完成后再進行下一步操作。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女