Go で同時マッピングを使用するにはどうすればよいですか?-Golang-php.cn

Go で同時マッピングを使用するにはどうすればよいですか?

王林

リリース： 2023-05-11 17:06:06

オリジナル

799 人が閲覧しました

Go 言語が発展し続けるにつれて、ますます多くの開発者がそれを使用して高同時実行性のアプリケーションを構築し始めています。同時実行アプリケーションでは、通常、データを保存および管理するためにマップデータ構造を使用する必要があります。 Go 言語はネイティブの Map 型を提供しますが、同時実行安全ではありません。同時環境で Map を使用する場合は、保護のためにミューテックスロックなどのメカニズムを使用する必要があります。ただし、このアプローチはパフォーマンスの低下につながるため、同時実行性の高い環境でのアプリケーションには適していません。したがって、この記事では、Go で同時マッピングを使用して、同時実行性の高いシナリオでアプリケーションのパフォーマンスと安定性を向上させる方法を紹介します。

1.同時マッピングとは何ですか?

同時マッピングは、同時環境での安全な読み取りおよび書き込み操作を保証できる特別なマッピングデータ構造です。通常、ハッシュテーブルに基づいて実装され、複数のコルーチンでマップ内の要素に同時にアクセスして変更できます。同時マッピングの実装では、スレッドの安全性と高いパフォーマンスを確保する必要があります。これは、同時実行性の高いアプリケーションにとって特に重要です。

Go 言語では、標準ライブラリはネイティブの同時マッピング実装を提供しません。したがって、効率的で正しい同時マッピングを自分たちで構築する必要があります。次に、同時マッピングを実装するための一般的な方法とテクニックをいくつか紹介します:

2. 同時マッピングの実装方法

sync.Map

## を使用します。 Go 言語の sync パッケージでは、ネイティブの同時マッピングタイプ - sync.Map が提供されます。これは、ロード、ストア、削除、範囲など、マッピング内の要素を管理するための一連のメソッドを提供し、同時かつ安全な読み取りおよび書き込み操作を簡単に実装できます。このタイプの実装はスレッドの安全性と効率性を確保できるため、良い選択です。

ただし、sync.Map はあらゆる状況に適しているわけではないことに注意してください。たとえば、Map 全体を走査する必要がある場合や、Map メッセージを並べ替える必要がある場合、または同様の操作を実行する必要がある場合には適していません。 sync.Map 内の要素の走査順序はランダムであり、具体的な配置順序は不確かであるためです。したがって、sync.Map を使用する場合は、特定のビジネスニーズに基づいて検討する必要があります。

次に、sync.Map の使用例を見てみましょう:

var syncMap sync.Map

syncMap.Store("key1", "value1")
value, ok := syncMap.Load("key1")
if ok {
    fmt.Println(value)
}

syncMap.Delete("key1")

ログイン後にコピー

ミューテックスロックに基づく同時マッピング実装方法は比較的単純で、ロックによってスレッドセーフが実現されます。 sync.Mutex タイプは Go 言語の標準パッケージで提供されており、ミューテックスロックを通じて同時実行の安全性を確保できます。ただし、ミューテックスのロックおよびロック解除操作には時間がかかるため、同時実行性が高いシナリオではパフォーマンスのボトルネックが発生しやすく、システムの同時実行機能に影響を与えることに注意してください。

以下は、ミューテックスロックに基づいた同時マッピングを実装するためのサンプルコードです:

type SafeMap struct {
    sync.Mutex
    data map[string]string
}

func (m *SafeMap) Load(key string) (value string, ok bool) {
    m.Lock()
    defer m.Unlock()
    value, ok = m.data[key]
    return
}

func (m *SafeMap) Store(key string, value string) {
    m.Lock()
    defer m.Unlock()
    m.data[key] = value
}

ログイン後にコピー

この例では、内部データマップとユーザーミューテックスロックを含む SafeMap タイプを定義します。マップをロックします。読み取りおよび書き込み操作を実行するときは、最初にミューテックスロックをロックし、次に読み取りおよび書き込み操作を実行し、最後にミューテックスロックを解除してスレッドの安全性を確保する必要があります。

3. コンカレントマッピングのパフォーマンスと注意事項

上記のコンカレントマッピングの実装方法では、パフォーマンステストを使用してパフォーマンスを比較できます。それらの間の。以下は、Benchmark を使用したパフォーマンステストのサンプルコードです。

func BenchmarkSafeMap(b *testing.B) {
    sm := SafeMap{data: make(map[string]string)}
    for i := 0; i < b.N; i++ {
        go func() {
            sm.Store("key1", "value1")
            sm.Delete("key1")
        }()
    }
}

ログイン後にコピー

SafeMap は読み取りおよび書き込み時にロックおよびロック解除の操作を必要とするため、パフォーマンステストにはある程度の損失が生じることに注意してください。 Sync.Map は、高度に最適化された同時実行安全アルゴリズムを使用しているため、パフォーマンステスト中にパフォーマンスのボトルネックが発生する可能性が低くなります。

同時マッピングの実装では、次の点に注意する必要があります。