Dans Go, comment fermer correctement les connexions de la base de données pour plusieurs goroutine partagée?

Clôture élégante de la connexion de base de données partagée GO multi-goroutine

Dans la programmation simultanée GO, comment fermer en toute sécurité la connexion est un problème critique lorsque plusieurs Goroutines partagent des connexions de base de données. La méthode d'arrêt incorrecte peut entraîner une perte de données ou un crash du programme. Cet article discutera de plusieurs solutions et analysera leurs avantages et leurs inconvénients.

Supposons que nous ayons un scénario: plusieurs goroutines effectuent simultanément les opérations de requête de la base de données, partageant la même connexion à la base de données.

Démonstration d'erreur: utilisez defer pour fermer la connexion dans le goroutine principal

Le code suivant démontre une erreur courante:

 db: = openndb ()
différer db.close () // Erreur: lorsque le goroutine principal est fermé, d'autres goroutines peuvent toujours être utilisés pour i: = 0; i <p> <code>defer db.Close()</code> sera exécuté à la fin de la goroutine principale, mais à ce moment, d'autres Goroutines peuvent toujours utiliser la connexion de la base de données, provoquant des accidents de programme ou des erreurs de données.</p><p> <strong>Démonstration d'erreur: connexion ferme dans chaque goroutine</strong></p><p> Mettre <code>db.Close()</code> dans chaque goroutine n'est pas non plus la bonne solution:</p><pre class="brush:php;toolbar:false"> func querydb (db * db, i int) {
    Defer db.close () // Erreur: chaque Goroutine essaie de fermer la connexion // ... Fonctionnement de la requête de la base de données ...
}

Cela entraîne la fermeture de la connexion plusieurs fois, lançant une erreur.

Solution correcte 1: Utilisez WaitGroup pour synchroniser la goroutine

L'utilisation sync.WaitGroup garantit que tous les Goroutines ont terminé leur travail avant de fermer la connexion:

 var wg sync.waitgroup
db: = openndb ()
différer db.close () // Correct: Fermer pour i: = 0; i <p> Cette méthode compte les goroutines par <code>wg.Add(1)</code> et <code>wg.Done()</code> et <code>wg.Wait()</code> bloquent jusqu'à ce que tous les goroutines soient terminés, garantissant que la connexion est fermée à un point sûr dans le temps.</p><p> <strong>Solution correcte 2: Utilisez les variables globales et le contrôle principal du goroutine</strong></p><p> Un autre moyen plus simple consiste à définir la connexion de la base de données comme une variable globale et à la gérer uniformément dans le goroutine principal:</p><pre class="brush:php;toolbar:false"> var db * db

func main () {
    db = openndb ()
    Déférer db.close () // Correct: Fermez uniformément dans le goroutine principal // ... Démarrez Goroutine ...
}

func querydb (i int) {
    // ... Fonctionnement de la requête de la base de données ...
}

De cette façon, se concentre clairement à la gestion des connexions sur la goroutine principale, en évitant les problèmes d'accès et de fermeture simultanés.

Quelle solution à choisir dépend du scénario d'application spécifique et de la complexité du code. La méthode WaitGroup convient à des scénarios simultanés plus complexes, tandis que la méthode de variable globale est plus concise et facile à comprendre dans des scénarios simples. La clé consiste à s'assurer que la connexion de la base de données n'est fermée qu'une seule fois et après tout les Goroutines ont terminé les opérations.

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!