14

大量のゴルーチンを開始し、それらの終了を待つ必要があります。直感的な方法は、チャネルを使用してすべてが完了するまで待機するようです。

package main

type Object struct {
    //data
}

func (obj *Object) Update(channel chan int) {
    //update data
    channel <- 1
    return
}

func main() {

    channel := make(chan int, n)
    list := make([]Object, n, m)
    for {
        for _, object := range list {
            go object.Update(channel)
        }
        for i := 0; i < n; i++ {
            <-channel
        }
        //now everything has been updated. start again
    }
}

しかし問題は、オブジェクトの量、したがってゴルーチンの量が変化する可能性があることです。チャネルのバッファ サイズを変更することはできますか?

これを行うためのよりエレガントな方法はありますか?

4

3 に答える 3

34

この問題の解決策としてWaitGroupを使用しました。何が起こっているのかを明確にするためにいくつかのログを使用して、現在のコードを翻訳します。

package main

import "sync"
import "fmt"
import "time"

type Object struct {
    //data
}

func (obj *Object) Update(wg *sync.WaitGroup) {
    //update data
    time.Sleep(time.Second)
    fmt.Println("Update done")
    wg.Done()
    return
}

func main() {
    var wg sync.WaitGroup
    list := make([]Object, 5)
    for {
        for _, object := range list {
            wg.Add(1)
            go object.Update(&wg)
        }
        //now everything has been updated. start again
        wg.Wait()
        fmt.Println("Group done")
    }
}
于 2013-05-16T15:10:22.633 に答える
4

このタスクは簡単ではありません。バグのあるタスクを作成するのは非常に簡単です。stdlib - で既製のソリューションを使用することをお勧めしますsync.WaitGroup。リンクから引用:

WaitGroup は、ゴルーチンのコレクションが終了するのを待ちます。メインのゴルーチンは Add を呼び出して、待機するゴルーチンの数を設定します。次に、各ゴルーチンが実行され、終了すると Done が呼び出されます。同時に、Wait を使用して、すべてのゴルーチンが終了するまでブロックできます。

于 2013-05-16T15:10:16.023 に答える