ゴーのWaitGroupを使った並行処理タスクによる効率的な処理

2年 ago
優斗, 朝陽
1 minute

Go言語では、syncパッケージのWaitGroup型を使用すれば、並行処理を効率よく実現できます。

WaitGroupはgoroutineのグループがタスクを完了するのを待つためのカウンタセマフォです。3つのメソッド、Add()、Done()、Wait()があります。

WaitGroupを使用してタスクを効率的に並列処理するサンプルコードを以下に示します。

package main
import (
"fmt"
"sync"
)
func main() {
numTasks := 10
var wg sync.WaitGroup
for i := 0; i < numTasks; i++ {
wg.Add(1)
go func(taskID int) {
defer wg.Done()
processTask(taskID)
}(i)
}
wg.Wait()
fmt.Println("All tasks completed")
}
func processTask(taskID int) {
fmt.Printf("Task %d started\n", taskID)
// 模拟耗时操作
for i := 0; i < 100000000; i++ {
}
fmt.Printf("Task %d completed\n", taskID)
}

こちらのサンプルでは、10個のタスクを作成し、WaitGroup に追加しました。各タスクの goroutine 内では Done() メソッドを呼び出してタスクの完了をマークします。

最後にmain関数でWait()メソッドを呼び出して全てのタスクの完了を待つ。全てのタスクが完了したら後続のコードを実行できる。

WaitGroupを使うことで、ゴルーチンの状態を手動で管理することなく、タスクを効率的に並列処理できます。すべてのタスクが完了したら、後続のコードの実行を続けることができます。

WaitGroupを使用する際は、各タスクのgoroutine内で必ずDone()メソッドを呼び出してカウンタを正しく減らすようにしてください。そうしないと、Wait()メソッドはブロックされ続け、プログラムの実行が続かなくなります。

此外，WaitGroup的计数器也可以通过Add()方法增加，以便在其他地方动态添加任务。同样，Done()方法也可以在其他地方调用，以便在不同的位置标记任务完成。

GoのWaitGroupを利用すると非同期並列処理タスクの効率的な実装が容易になり、並列プログラミングの複雑さが軽減され、全てのタスク完了を待機するためのエレガントな方法が提供される。

bannerAds