亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

如何使用Go WaitGroup處理并發任務

小云
101
2023-10-09 08:12:00
欄目: 編程語言

在 Go 中使用 sync.WaitGroup 來處理并發任務,可以確保在所有任務完成之前等待主程序的執行。下面是一個簡單的例子:

package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
numTasks := 10
// 增加任務數
wg.Add(numTasks)
for i := 0; i < numTasks; i++ {
go func(taskNum int) {
defer wg.Done() // 每個任務執行完成后減少任務數
fmt.Printf("Task %d is running\n", taskNum)
// 執行具體任務
}(i)
}
// 等待所有任務完成
wg.Wait()
fmt.Println("All tasks are completed")
}

在上面的例子中,我們首先創建了一個 WaitGroup 對象 wg,然后使用 Add() 方法增加了需要等待的任務的數量。在每個任務的 goroutine 中,我們使用 defer wg.Done() 來在任務執行完畢后減少任務數。最后,我們使用 Wait() 方法來等待所有任務完成,然后輸出相應的信息。

對于每個任務,你可以在 go func() 中執行具體的任務邏輯,例如進行數據處理、調用 API,或者執行其他操作。每個任務完成時,調用 wg.Done() 來減少任務數。

使用 sync.WaitGroup 的好處是可以確保在所有任務完成之前主程序不會退出。

0
长沙县| 塘沽区| 锡林浩特市| 乌恰县| 古浪县| 黔南| 太白县| 丹江口市| 葵青区| 尚志市| 定西市| 沂南县| 从江县| 浮山县| 新化县| 安岳县| 司法| 海盐县| 海安县| 新余市| 海丰县| 广元市| 沐川县| 石屏县| 疏勒县| 紫金县| 苍南县| 北安市| 探索| 定边县| 桃江县| 平湖市| 唐山市| 博客| 自贡市| 辽宁省| 同江市| 永川市| 长子县| 灌阳县| 会泽县|