ホームページ > バックエンド開発 > Golang > マイクロサービス アーキテクチャにおける golang 関数の同時実行制御のベスト プラクティス

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

王林
リリース: 2024-04-24 17:09:02
オリジナル
561 人が閲覧しました

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

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

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

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

ベスト プラクティス:

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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

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()

}

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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

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 つのルーチンのみが共有リソースにアクセスできます。これは、データの競合や破損を防ぐのに役立ちます。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

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 間の非同期通信のためのメカニズムです。これはルーチンを分離し、同時実行性を向上させるのに役立ちます。

1

2

3

4

5

6

7

8

9

10

11

12

import (

    "fmt"

)

 

func main() {

    ch := make(chan int)

    go func() {

        ch <- 10

    }()

    v := <-ch

    fmt.Printf("Received: %d\n", v)

}

ログイン後にコピー

実際的なケース:

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

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

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 サイトの他の関連記事を参照してください。

このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート