sync.waitgroupを使用して、複数のゴルチンが完了するのを待つ方法-Golang-php.cn

sync.waitgroupを使用して、複数のゴルチンが完了するのを待つ方法

James Robert Taylor

リリース： 2025-03-19 14:51:31

オリジナル

482 人が閲覧しました

sync.waitgroupを使用して、複数のゴルチンが完了するのを待つ方法

sync.WaitGroupを使用して複数のゴルチンが完了するのを待つには、次の手順に従います。

Waitgroupの初期化：まず、 sync.WaitGroupのインスタンスを作成する必要があります。これは通常、単純な宣言を使用して行われます。
```
 <code class="go">var wg sync.WaitGroup</code>
```
ログイン後にコピー
WaitGroupに追加：ゴルチンを起動する前に、開始する各ゴルチンのウェイトグループカウンターを増やします。これは、待機groutinesが何回待つ必要があるかを示しています。
```
 <code class="go">wg.Add(1)</code>
```
ログイン後にコピー
Goroutinesを開始：ゴルウチン関数では、延期ステートメントを使用して、ゴルウチンが完了したときにカウンターを減少させます。これにより、パニックのためにゴルウチンが時期尚早に終了する場合でも、カウンターが減少することが保証されます。
```
 <code class="go">go func() { defer wg.Done() // Goroutine work here }()</code>
```
ログイン後にコピー
完了を待つ：すべてのゴロウチンを起動した後、WaitGroupでWait()を呼び出します。これにより、カウンターがゼロになるまでメインゴルウチンの実行がブロックされます。つまり、追跡されたすべてのゴロウチンが完了しました。
```
 <code class="go">wg.Wait()</code>
```
ログイン後にコピー

これが完全な例です：

 <code class="go">package main import ( "fmt" "sync" "time" ) func main() { var wg sync.WaitGroup for i := 1; i </code>

ログイン後にコピー

Goroutinesでsync.waitgroupを使用するときに避けるべき一般的な落とし穴は何ですか？

sync.WaitGroupを使用する場合、避けるべきいくつかの一般的な落とし穴があります。

ゴロウチンを開始する前にAddを忘れて： Addを呼び出す前にゴロウチンを起動する場合、ウェイトグループカウンターは待機する正しい数のゴルチンを反映していないため、 Wait()コールの早期終了につながります。
誤用AddとDone ：すべてのAdd(1)コールに対応するDone()呼び出しがあることを確認してください。これらが不一致の場合、プログラムは無期限にハングするか、 Wait()早期に戻ります。
AddおよびDoneレース条件： WaitでAddまたは同時にDoneように注意してください。よくある間違いは、 Doneゴルチンを起動した後にAddを呼び出すことです。
Doneにdeferを使用していない：Goroutineの開始時にdefer wg.Done()を使用することをお勧めします。これにより、Goroutineパニックであっても、 Done呼び出されることが保証されます。
エラーを無視する：ゴルチンが失敗する可能性のある操作を実行している場合は、エラーを適切に処理し、メインゴルウチンに通信してください。

sync.waitgroupは、同時運用のライフサイクルの管理にどのように役立ちますか？

sync.WaitGroup 、複数のゴルチンの完了を同期するための簡単なメカニズムを提供することにより、同時操作のライフサイクルを管理するのに役立ちます。それがどのように役立つかは次のとおりです。

同期： sync.WaitGroup 、メインのゴルウチンがすべての産卵したゴルチンが進む前にタスクを完了するのを待つことを保証します。これは、同時プログラムで正しい運用順序を維持するために重要です。
ライフサイクル管理：完了する必要があるゴルウチンの数を追跡することにより、 sync.WaitGroupこれらのゴルチンのライフサイクルを管理するのに役立ちます。これにより、プログラムはすべての操作がいつ終了するかを知ることができます。これは、クリーンアップ、リソースのリリース、またはさらに処理に不可欠です。
エラー処理： sync.WaitGroup自体はエラーを処理しませんが、すべてのゴルチンが終了した後に個々のゴルチンからのエラーを収集および処理できる並行性に対する構造化されたアプローチを容易にします。
スケーラビリティ： sync.WaitGroupゴルチンの数とよくスケーリングします。 2〜2,000個のゴルウチンがあるかどうかにかかわらず、メカニズムは同じままであり、小さなスクリプトから大規模なシステムに至るまでのアプリケーションに適しています。

GOプログラムでSync.waitgroupを初期化して使用するためのベストプラクティスは何ですか？

GOプログラムでsync.WaitGroup初期化して使用するときのベストプラクティスに従うことで、効率的かつ正しい並行性管理を確保できます。これが重要なプラクティスです：

waitgroupをローカルに初期化： sync.WaitGroupを初期化する関数またはスコープ内で必要な場合。これにより、偶発的な再利用と潜在的な人種条件の可能性が減ります。
```
 <code class="go">func someFunction() { var wg sync.WaitGroup // Use wg within this function }</code>
```
ログイン後にコピー
Goroutinesを開始する前にAddを使用してください：ゴルウチンを開始する前に、必ずAddを呼び出してください。これによりAddが呼び出される前にゴロウチンが終了する可能性のある人種条件を回避します。
```
 <code class="go">wg.Add(1) go func() { defer wg.Done() // Goroutine work }()</code>
```
ログイン後にコピー
延期Done通話：ゴルチンの先頭にdefer wg.Done()を使用して、たとえゴルウチンパニックであっても、呼び出されていることを確認してください。
```
 <code class="go">go func() { defer wg.Done() // Goroutine work }()</code>
```
ログイン後にコピー
Waitgroupの再利用を避ける： sync.WaitGroupがライフサイクルを完了したら（つまり、 Waitが戻った後）、再利用しないでください。 Goroutinesの新しいセット用に新しいsync.WaitGroupを作成します。
エラーの処理： Waitが戻った後、ゴルチンからエラーを収集して処理します。チャネルまたはその他の同期メカニズムを使用して、エラーをメインゴルチンに戻すことができます。
```
 <code class="go">errors := make(chan error, len(workers)) for _, worker := range workers { wg.Add(1) go func(w Worker) { defer wg.Done() if err := w.DoWork(); err != nil { errors </code>
```
ログイン後にコピー