Go言語で並行・並列処理を実装するときの大量の命令を書く方法について

Question

実現したいこと。

go ルーチンで処理を書くときに、大量の命令を書く場合についての良い方法が知りたいです。

例

    ch1 := make(chan bool)
    ch2 := make(chan bool)
    ch3 := make(chan bool)

        go func(){
            xxxxx（←時間がかかる処理 10秒）
            ch1 <- true
        }()
        go func(){
            xxxxx（←時間がかかる処理 10秒）
            ch2 <- true
        }()
        go func(){
            xxxxx（←時間がかかる処理 10秒）
            ch3 <- true
        }()

        <-ch1
        <-ch2
        <-ch3

こういう場合は、ゴールーチンを使わないと30秒かかる処理が、10秒で完了できます。

ただ、今回は3つだけ関数があるだけでいいのですが、これが100個必要となったときに、100個関数を書かなくてはいけないのか？と思ってしまい、何かいい方法がないか知りたいです。

ご存知の方いらっしゃいましたらご教示いただけませんでしょうか？

Answer 1

この事例では手で書いたコードをきっかけにgoroutineを起動する流れですが、たとえば
sync.WaitGroupを使って複数のgoroutineの終了を待つやりかたなら任意の数のgoroutineを起動して終了を待つことができます。

const N = 10
var wg sync.WaitGroup
defer wg.Wait()
for i:=0; i<N; i++ {
    wg.Add(1)
    go func(){
        defer wg.Done()
        // 時間のかかる処理
    }()
}

また、実際のコードは何かの条件が成立したらgoroutineを起動する使われ方が多いと思います。

1番よくみる使い方はhttpサーバーの実装でクライアントが接続してくる度にgoroutineを起動すると言う使い方ですね。
こうすると複数のクライアントの相手を並行して行えるようになります。

また、並列度というワードを検索してみましょう。実際のコードは複数のgoroutineの関係を完全に無関係に保つのは難しく、どこかしら直列に動く部分が残ります。例えばタスクを分割する処理やログ出力など。
並列度100%なら処理を三つのgoroutineに分けると3倍速くなるのですが、実際には並列動作をめざしても直列動作がいくらか含まれることになり並列度が100%にならず三つのgoroutineに処理を分けたら3倍速くなる状況を維持することは実用的なコードであればあるほど難しくなります。

例えば95%の並列度ならアムダールの法則により仮に無限のコアを持つマシンで無限のgoroutineで並行に動かしても20倍より速くなることはありません。

Comments

[EzrealTrueshot]

ありがとうございます！