Maison  >  Article  >  développement back-end  >  Comment utiliser le mappage simultané dans Go ?

Comment utiliser le mappage simultané dans Go ?

王林
王林original
2023-05-11 17:06:06905parcourir

Avec le développement continu du langage Go, de plus en plus de développeurs ont commencé à l'utiliser pour créer des applications à haute concurrence. Dans les applications concurrentes, il est généralement nécessaire d'utiliser une structure de données cartographiques pour stocker et gérer les données. Le langage Go fournit un type Map natif, mais il n’est pas sécurisé en matière de concurrence. Lorsque vous utilisez Map dans un environnement simultané, vous devez utiliser des mécanismes tels que les verrous mutex pour la protection. Cependant, cette approche entraînera une dégradation des performances et n’est pas propice aux applications dans des environnements à forte concurrence. Par conséquent, cet article explique comment utiliser le mappage simultané dans Go pour améliorer les performances et la stabilité des applications dans des scénarios à forte concurrence.

1. Qu'est-ce que la cartographie simultanée ?

Le mappage simultané est une structure de données de mappage spéciale qui peut garantir des opérations de lecture et d'écriture sécurisées dans un environnement simultané. Il est généralement implémenté sur la base d'une table de hachage et peut accéder et modifier simultanément les éléments de la carte dans plusieurs coroutines. La mise en œuvre du mappage simultané doit garantir la sécurité des threads et des performances élevées, ce qui est particulièrement important pour les applications à haute concurrence.

Dans le langage Go, la bibliothèque standard ne fournit pas d'implémentation native de mappage simultané. Par conséquent, nous devons construire nous-mêmes une cartographie concurrente efficace et correcte. Ensuite, nous présenterons quelques méthodes et techniques courantes pour implémenter le mappage simultané :

2. Comment implémenter le mappage simultané

  1. Utilisez sync.Map

Dans le package de synchronisation du langage Go, un mappage simultané natif est fourni Type - sync.Map. Il fournit une série de méthodes pour gérer les éléments du mappage, telles que Load, Store, Delete et Range, qui peuvent facilement implémenter des opérations de lecture et d'écriture simultanées et sécurisées. Ce type d'implémentation peut garantir la sécurité et l'efficacité des threads et constitue un bon choix.

Cependant, il convient de noter que sync.Map ne convient pas à toutes les occasions. Par exemple, il ne convient pas lorsque vous devez parcourir toute la carte ou trier les messages de la carte ou effectuer des opérations similaires. Parce que l'ordre de parcours des éléments dans sync.Map est aléatoire et l'ordre de disposition spécifique est incertain. Par conséquent, lorsque vous utilisez sync.Map, vous devez le considérer en fonction des besoins spécifiques de votre entreprise.

Ensuite, jetons un coup d'œil à l'exemple d'utilisation de sync.Map :

var syncMap sync.Map

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

syncMap.Delete("key1")
  1. Implémentation basée sur le verrouillage mutex

L'implémentation du mappage simultané basé sur le verrouillage mutex est relativement simple et la sécurité des threads est obtenue grâce au verrouillage. Le type sync.Mutex est fourni dans le package standard du langage Go, qui peut garantir la sécurité de la concurrence grâce aux verrous mutex. Cependant, il convient de noter que, étant donné que les opérations de verrouillage et de déverrouillage du mutex prennent du temps, des goulots d'étranglement en termes de performances sont susceptibles de se produire dans les scénarios à forte concurrence, affectant les capacités de concurrence du système.

Ce qui suit est un exemple de code pour implémenter un mappage simultané basé sur des verrous mutex :

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
}

Dans cet exemple, nous définissons un type SafeMap, qui contient une carte de données interne et un verrou mutex pour verrouiller la carte. Lorsque vous effectuez des opérations de lecture et d'écriture, vous devez d'abord verrouiller le verrou mutex, puis effectuer des opérations de lecture et d'écriture, et enfin déverrouiller le verrou mutex pour garantir la sécurité des threads.

3. Performances et précautions du mappage simultané

  1. Comparaison des performances

Dans les méthodes de mise en œuvre du mappage simultané ci-dessus, nous pouvons utiliser des tests de performances pour comparer les performances entre elles. Voici un exemple de code pour les tests de performances à l'aide de 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")
        }()
    }
}

Il convient de noter que SafeMap nécessite des opérations de verrouillage et de déverrouillage lors de la lecture et de l'écriture, il y a donc une certaine perte dans le test de performances. Sync.Map utilise des algorithmes de sécurité de concurrence hautement optimisés, de sorte que les goulots d'étranglement des performances sont moins susceptibles de se produire lors des tests de performances.

  1. Remarques

Dans la mise en œuvre du mappage simultané, vous devez faire attention aux points suivants :

  • Besoin d'assurer la sécurité des threads et de la gérer via des mécanismes tels que les verrous mutex.
  • L'efficacité doit être garantie et les opérations fastidieuses telles que la copie de données doivent être évitées autant que possible.
  • Les blocages doivent être évités, et des précautions particulières doivent être prises lors de l'utilisation entre plusieurs mappages.

4. Résumé

Dans cet article, nous avons présenté le concept de mappage simultané et deux méthodes d'implémentation du mappage simultané en langage Go : basé sur sync.Map et basé sur des verrous mutex. Dans le même temps, nous avons également discuté de la manière de choisir la solution la plus adaptée dans la pratique, ainsi que des précautions et des tests de performances.

Comprendre le concept et la mise en œuvre du mappage simultané est important pour créer des applications à haute concurrence. En pratique, nous devons choisir la méthode de mise en œuvre du mappage simultané la plus appropriée en fonction des besoins spécifiques de l'entreprise afin d'améliorer les performances et la stabilité des applications dans des scénarios à forte concurrence.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn