Maison  >  Article  >  développement back-end  >  Comment pouvez-vous parvenir à une exclusion mutuelle dans des Goroutines simultanées à l'aide de Mutex ?

Comment pouvez-vous parvenir à une exclusion mutuelle dans des Goroutines simultanées à l'aide de Mutex ?

Susan Sarandon
Susan Sarandonoriginal
2024-10-30 05:50:28541parcourir

How can you achieve mutual exclusion in concurrent Goroutines using Mutexes?

Exclusion mutuelle dans les goroutines simultanées utilisant Mutex

Le concept d'exclusion mutuelle régit l'exécution simultanée de fonctions ou de blocs de code dans un programme. Dans un environnement de programmation simultanée, où plusieurs routines s'exécutent indépendamment, le maintien de l'exclusion mutuelle est crucial pour garantir l'exactitude et prévenir les conflits.

Problème :
Considérons un scénario avec trois goroutines simultanées (Routine 1, 2 et 3), qui échangent des données et effectuent des opérations d'impression. L'objectif est de garantir que pendant l'exécution d'une section spécifique de code dans une goroutine, l'exécution dans d'autres goroutines est interrompue jusqu'à ce que cette section soit terminée.

Solution utilisant Mutex :
Mutex , une primitive de synchronisation fondamentale, peut être utilisée pour réaliser une exclusion mutuelle dans les goroutines. Les mutex fournissent un mécanisme de verrouillage qui permet à une seule goroutine d'accéder à une section critique de code à la fois.

Dans l'extrait de code fourni, trois mutex (mutex1, mutex2 et mutex3) ont été introduits :

var (
    mutex1, mutex2, mutex3 sync.Mutex
    wg sync.WaitGroup
)

Chaque goroutine acquiert le mutex approprié avant d'exécuter la section critique, comme indiqué dans le code révisé :

func Routine1() {
    mutex1.Lock()
    // do something
    ...
    // do something
    mutex1.Unlock()
    ...
}

func Routine2() {
    mutex2.Lock()
    ...
    // do something
    ...
    mutex2.Unlock()
    ...
}

func Routine3() {
    ...
    mutex3.Lock()
    // do something
    ...
    mutex3.Unlock()
    ...
}
  • Routine1 acquiert mutex1 lors de l'exécution de la section critique, bloquant les autres routines de accéder à cette section.
  • Routine2 acquiert mutex2, assurant l'exécution exclusive de sa section critique.
  • Routine3 acquiert mutex3 pour contrôler l'accès à sa section critique.

Groupe d'attente et synchronisation :
De plus, un groupe d'attente (wg) a été utilisé pour synchroniser les goroutines :

wg.Add(3)
go Routine1()
go Routine2()
Routine3()
wg.Wait()
  • La méthode Add incrémente le compteur du groupe d'attente de 3 , indiquant que trois goroutines sont sur le point de s'exécuter.
  • L'instruction go запускает Routine1 et Routine2 simultanément.
  • La routine3 est exécutée dans le thread actuel.
  • La méthode Wait se bloque jusqu'à ce que le compteur de groupe d'attente atteint zéro, garantissant que toutes les goroutines ont terminé leur exécution avant que la fonction principale ne continue.

Résultat :
Avec cette implémentation, l'exécution des sections critiques dans les goroutines s’excluront mutuellement. En conséquence, les opérations d'impression de chaque routine ne se chevaucheront pas ou ne seront pas entrelacées, évitant ainsi les conditions de concurrence et produisant le résultat attendu.

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