マイクロサービス アーキテクチャにおける golang 関数の同時実行制御のベスト プラクティス

マイクロサービス アーキテクチャにおける Golang 関数の同時実行制御のベスト プラクティスには、WaitGroup を使用して同時実行ルーチンを調整し、すべてのルーチンが実行された後もメイン ルーチンが確実に実行を継続できるようにすることが含まれます。セマフォを使用して同時実行制限を制御し、システムの過負荷を防ぎます。 Mutex を使用して共有リソースへのアクセスをシリアル化し、データ競合を防ぎます。 Goroutine チャネルを使用して、Goroutine 間の非同期通信を実装し、ルーチンを分離して同時実行性を向上させます。

マイクロサービス アーキテクチャにおける Golang 関数の同時実行制御のベスト プラクティス

マイクロサービス アーキテクチャでは、関数の同時実行制御はパフォーマンスの最適化に重要ですそしてスケーラビリティが重要です。 Golang は、関数の同時実行性を効果的に制御するためのメカニズムをいくつか提供します。

ベスト プラクティス:

• WaitGroup を使用して同時ルーチンを調整する: WaitGroup は、同時ルーチンのグループが完了するのを待機するために使用されます。 。これは、メイン ルーチンが続行できる前に、すべてのルーチンの実行が確実に完了するようにするのに役立ちます。

import (
    "sync"
    "time"
)

var wg sync.WaitGroup

func main() {
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            time.Sleep(time.Second)
            wg.Done()
        }()
    }
    wg.Wait()
}

• セマフォを使用して同時実行の上限を制御する: セマフォは、同時に実行できるルーチンの数を制限します。これは、システムの過負荷やクラッシュを防ぐのに役立ちます。

import (
    "fmt"
    "sync"
)

var sem = make(chan int, 10)

func main() {
    for i := 0; i < 20; i++ {
        go func(i int) {
            sem <- 1
            fmt.Printf("Routine %d started\n", i)
            time.Sleep(time.Second)
            <-sem
        }(i)
    }
}

• ミューテックスを使用して共有リソースへのアクセスをシリアル化する: ミューテックスを使用すると、一度に 1 つのルーチンのみが共有リソースにアクセスできます。これは、データの競合や破損を防ぐのに役立ちます。

import (
    "fmt"
    "sync"
)

var m = sync.Mutex{}
var counter = 0

func main() {
    for i := 0; i < 1000; i++ {
        go func() {
            m.Lock()
            counter++
            fmt.Printf("Counter: %d\n", counter)
            m.Unlock()
        }()
    }
}

• Goroutines チャネルを使用した通信: Goroutines チャネルは、Goroutines 間の非同期通信のためのメカニズムです。これはルーチンを分離し、同時実行性を向上させるのに役立ちます。

import (
    "fmt"
)

func main() {
    ch := make(chan int)
    go func() {
        ch <- 10
    }()
    v := <-ch
    fmt.Printf("Received: %d\n", v)
}

実際的なケース:

次は、WaitGroup を使用して同時ルーチンを調整する実際的な例です:

package main

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

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()
            fmt.Println(i)
            time.Sleep(time.Second)
        }(i)
    }
    wg.Wait()
}

以上がマイクロサービス アーキテクチャにおける golang 関数の同時実行制御のベスト プラクティスの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。