Go 言語で同時実行数を制御する方法

Go 言語は同時実行をサポートしているため、面接では同時実行に関する質問がよく聞かれます。たとえば、Go 同時実行の数を制御する方法は何ですか?以下は私が個人的にコンパイルした 2 つの例です:

func waitGroup() {
    count := 10
    wg := sync.WaitGroup{}

    for i := 0; i < count; i++ {
        wg.Add(1)
        go func(j int) {
            fmt.Print(j)
            wg.Done() // 也可使用 wg.Add(-1)
        }(i)
    }

    wg.Wait()
}

上記は主に go の sync パッケージ配下の waitGroup を使用しています。これは仕事でも一般的な実装方法でもあります。重要な点は、Add メソッドを把握することです。位置、Wait メソッドは、すべてのコルーチンが実行されるのを待ちます

func channel() {
    count := 10 // 最大支持并发
    sum := 100 // 任务总数

    c := make(chan struct{}, count) // 控制任务并发的chan
    sc := make(chan struct{}, sum) // 控制任务总数的chan
    defer close(c)
    defer close(sc)

    for i:=0; i<sum;i++{
        c <- struct{}{} // 作用类似于waitgroup.Add(1)
        go func(j int) {
            fmt.Println(j)
            <- c // 执行完毕，释放资源
            sc <- struct {}{} // 记录到执行总数里
        }(i)
    }

    for i:=sum; i>0;i-- {
        <- sc
    }
}

上の例では、チャネル ブロッキング機能とバッファリングされたチャネルを使用して、同時実行数を制御するために、GO チャネルを使用します。ここで、sc このチャネルこの例では、メイン プログラムが終了した後にすべての出力が出力されないことを防ぐためにのみ使用されていますが、通常の動作では、プログラムは通常ブロックされているため、削除できます。

さらに関連する知識については、go 言語チュートリアルのコラムをご覧ください。

以上がGo 言語で同時実行数を制御する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。