GoのWaitGroupを使った複雑なタスクの分解による高性能コンピューティング

2年 ago
蓮, 翼
1 minute

複雑なタスクを分解・並列処理することで計算効率が向上し、Go言語におけるWaitGroup型はタスクの分解と並列化に利用できる。

WaitGroupは、一連の並列操作の完了を待機するカウントセマフォです。依存関係がタスク間で存在する場合に、複雑なタスクを処理する際に特に便利です。

WaitGroupを使用して複雑なタスクを分割する例を以下に示します。

package main
import (
"fmt"
"sync"
)
func main() {
// 创建一个WaitGroup实例
var wg sync.WaitGroup
// 设置计数器，表示需要等待的goroutine数量
wg.Add(2)
// 启动第一个goroutine进行任务A
go func() {
defer wg.Done()
// 执行任务A的代码
// ...
fmt.Println("Task A completed")
}()
// 启动第二个goroutine进行任务B
go func() {
defer wg.Done()
// 执行任务B的代码
// ...
fmt.Println("Task B completed")
}()
// 等待所有goroutine完成
wg.Wait()
fmt.Println("All tasks completed")
}

上記サンプルでは、最初にWaitGroupインスタンスを作成し、カウンターを2にセットします。これは、2つのgoroutineが完了するまで待機する必要があることを示しています。次に、2つのgoroutineを起動してそれぞれタスクAとタスクBを実行します。各goroutineはタスクの実行後にwg.Done()を呼び出すことでカウンターを1減らします。最後に、wg.Wait()を呼び出すことですべてのgoroutineが完了するまで待機します。

WaitGroupを使えば、複雑な処理を細かなタスクに分解して並列的に実行し、処理効率を向上させることができます。またWaitGroupでは、Add()やDone()といったメソッドが提供されており、カウンタの値を動的に調整することで並列実行するタスク数をより柔軟に制御できます。

bannerAds