Maison développement back-end Golang Comment puis-je collecter en toute sécurité des données à partir de plusieurs threads Go tout en évitant les conditions de concurrence ?

Comment puis-je collecter en toute sécurité des données à partir de plusieurs threads Go tout en évitant les conditions de concurrence ?

Jan 04, 2025 am 09:29 AM

How Can I Safely Collect Data from Multiple Go Threads While Preventing Race Conditions?

Collecte sécurisée de données à partir de plusieurs threads dans Go

L'accès simultané à des données partagées sur plusieurs threads sans synchronisation appropriée peut entraîner un comportement indéfini dans Go. Ceci est particulièrement critique pour les scénarios impliquant à la fois des opérations de lecture et d'écriture.

Risques d'accès simultanés

Dans votre cas, plusieurs threads de travail s'exécutent en parallèle, tandis que le thread principal cherche périodiquement à collecter des valeurs auprès de ces travailleurs. Si rien n'est fait, des situations de concurrence critique peuvent survenir, dans lesquelles plusieurs threads tentent d'accéder simultanément aux mêmes données, ce qui risque de les corrompre.

Options de synchronisation

Pour éviter les problèmes d'accès simultanés, vous devez utiliser des mécanismes de synchronisation. Une approche couramment utilisée consiste à utiliser les canaux, qui facilitent l'échange sécurisé de données entre les goroutines. Cependant, dans votre cas, les canaux ne constituent peut-être pas l'option la plus efficace, car vous cherchez à récupérer les données des travailleurs plutôt que de les laisser les envoyer de manière proactive.

Données protégées par Mutex

Une solution plus adaptée consiste à protéger la structure de données partagée à l'aide d'une primitive de synchronisation telle qu'un sync.RWMutex. Ce verrou garantit qu'un seul thread peut modifier les données à la fois tout en permettant à plusieurs threads d'y accéder simultanément pour la lecture.

Exemple d'implémentation

Voici une implémentation simplifiée utilisant a sync.RWMutex :

type Worker struct {
    iterMu sync.RWMutex
    iter   int
}

func (w *Worker) Iter() int {
    w.iterMu.RLock()
    defer w.iterMu.RUnlock()
    return w.iter
}

func (w *Worker) setIter(n int) {
    w.iterMu.Lock()
    w.iter = n
    w.iterMu.Unlock()
}
Copier après la connexion

Dans cet exemple, la méthode Iter du travailleur acquiert un verrou en lecture et renvoie le courant nombre d'itérations. La méthode setIter acquiert un verrou en écriture, met à jour le nombre d'itérations et libère le verrou.

Vous pouvez également utiliser le package sync/atomic pour fournir des opérations atomiques sur un compteur entier, éliminant ainsi le besoin d'un verrouillage explicite :

type Worker struct {
    iter int64
}

func (w *Worker) Iter() int64 {
    return atomic.LoadInt64(&w.iter)
}

func (w *Worker) setIter(n int64) {
    atomic.StoreInt64(&w.iter, n)
}
Copier après la connexion

En utilisant des techniques de synchronisation appropriées, vous pouvez collecter en toute sécurité des données à partir de plusieurs threads dans Go, garantissant ainsi l'intégrité des données et évitant les conditions de 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 de ce site Web
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

Outils d'IA chauds

Undresser.AI Undress

Undresser.AI Undress

Application basée sur l'IA pour créer des photos de nu réalistes

AI Clothes Remover

AI Clothes Remover

Outil d'IA en ligne pour supprimer les vêtements des photos.

Undress AI Tool

Undress AI Tool

Images de déshabillage gratuites

Clothoff.io

Clothoff.io

Dissolvant de vêtements AI

AI Hentai Generator

AI Hentai Generator

Générez AI Hentai gratuitement.

Article chaud

R.E.P.O. Crystals d'énergie expliqués et ce qu'ils font (cristal jaune)
2 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Repo: Comment relancer ses coéquipiers
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD

Outils chauds

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

GO Language Pack Import: Quelle est la différence entre le soulignement et sans soulignement? GO Language Pack Import: Quelle est la différence entre le soulignement et sans soulignement? Mar 03, 2025 pm 05:17 PM

GO Language Pack Import: Quelle est la différence entre le soulignement et sans soulignement?

Comment mettre en œuvre le transfert d'informations à court terme entre les pages du cadre Beego? Comment mettre en œuvre le transfert d'informations à court terme entre les pages du cadre Beego? Mar 03, 2025 pm 05:22 PM

Comment mettre en œuvre le transfert d'informations à court terme entre les pages du cadre Beego?

Comment convertir la liste des résultats de la requête MySQL en une tranche de structure personnalisée dans le langage Go? Comment convertir la liste des résultats de la requête MySQL en une tranche de structure personnalisée dans le langage Go? Mar 03, 2025 pm 05:18 PM

Comment convertir la liste des résultats de la requête MySQL en une tranche de structure personnalisée dans le langage Go?

Comment puis-je définir des contraintes de type personnalisé pour les génériques en Go? Comment puis-je définir des contraintes de type personnalisé pour les génériques en Go? Mar 10, 2025 pm 03:20 PM

Comment puis-je définir des contraintes de type personnalisé pour les génériques en Go?

Comment écrire des objets et des talons simulés pour les tests en Go? Comment écrire des objets et des talons simulés pour les tests en Go? Mar 10, 2025 pm 05:38 PM

Comment écrire des objets et des talons simulés pour les tests en Go?

Comment écrire des fichiers dans GO Language de manière pratique? Comment écrire des fichiers dans GO Language de manière pratique? Mar 03, 2025 pm 05:15 PM

Comment écrire des fichiers dans GO Language de manière pratique?

Comment rédigez-vous des tests unitaires en Go? Comment rédigez-vous des tests unitaires en Go? Mar 21, 2025 pm 06:34 PM

Comment rédigez-vous des tests unitaires en Go?

Comment puis-je utiliser des outils de traçage pour comprendre le flux d'exécution de mes applications GO? Comment puis-je utiliser des outils de traçage pour comprendre le flux d'exécution de mes applications GO? Mar 10, 2025 pm 05:36 PM

Comment puis-je utiliser des outils de traçage pour comprendre le flux d'exécution de mes applications GO?

See all articles