Go での同期のためにチャネル上で sync.WaitGroup を使用する必要があるのはどのような場合ですか?-Golang-php.cn

Go での同期のためにチャネル上で sync.WaitGroup を使用する必要があるのはどのような場合ですか?

DDD

リリース： 2024-11-25 10:07:14

オリジナル

873 人が閲覧しました

When should you use sync.WaitGroup over channels for synchronization in Go?

チャネルに対する sync.WaitGroup の利点

並行プログラミングでは、ゴルーチン間の同期が重要です。 sync.WaitGroup とチャネルは両方とも同期の手段を提供しますが、アプローチと使用法が異なります。

sync.WaitGroup

sync.WaitGroupゴルーチンのグループがタスクを完了するのを待つ方法を提供します。これはアクティブなゴルーチンの数を維持することによって動作し、各ゴルーチンは Done() メソッドを呼び出すことによって完了を通知します。 Wait() メソッドは、グループ内のすべての goroutine が呼び出し完了するまで、呼び出し中の goroutine をブロックします。 Done().

例:

import (
    "fmt"
    "sync"
    "time"
)

var wg sync.WaitGroup

func main() {
    words := []string{"foo", "bar", "baz"}

    for _, word := range words {
        wg.Add(1)
        go func(word string) {
            time.Sleep(1 * time.Second)
            defer wg.Done()
            fmt.Println(word)
        }(word)
    }

    // Waits for goroutines to finish
    wg.Wait()
}

ログイン後にコピー

利点:

シンプルさ: よりわかりやすく、 implement.
Blocking: すべての goroutine が完了するまで呼び出し元の goroutine をブロックし、実行順序を確保します。
Scalability: 複数の goroutine グループを処理できます。一方、

チャネル

チャネルは、ゴルーチン間で通信およびデータ交換する方法を提供します。これらはチャネルを介して値を送受信することによって動作し、複数のゴルーチンは同じものに対して同時に読み取りまたは書き込みを行うことができます。チャンネル。

例:

import (
    "fmt"
    "time"
)

func main() {
    words := []string{"foo", "bar", "baz"}
    done := make(chan bool)

    for _, word := range words {
        go func(word string) {
            time.Sleep(1 * time.Second)
            fmt.Println(word)
            done <- true
        }(word)
    }

    // Wait for goroutines to finish
    for range words {
        <-done
    }
}

ログイン後にコピー

利点: