Wie können Datenbankverbindungen für mehrere gemeinsame Goroutine korrekt geschlossen werden?

Eleganter Abschluss von Go Multi-Goroutine Shared Database Connection

Bei der gleichzeitigen Programmierung ist das sichere Schließen der Verbindung ein kritisches Problem, wenn mehrere Goroutinen Datenbankverbindungen teilen. Eine unsachgemäße Abschaltmethode kann zu Datenverlust oder Programmabsturz führen. In diesem Artikel werden mehrere Lösungen erörtert und ihre Vor- und Nachteile analysiert.

Angenommen, wir haben ein Szenario: Mehrere Goroutines führen Datenbankabfragen gleichzeitig aus und teilen die gleiche Datenbankverbindung.

Fehlerdemonstration: Verwenden Sie defer der Verbindung in der Haupt -Goroutine, um die Verbindung zu schließen

Der folgende Code zeigt einen gemeinsamen Fehler:

 DB: = Opendb ()
Defer db.close () // Fehler: Wenn die Haupt -Goroutine geschlossen ist, können andere Goroutinen immer noch für i: = 0 verwendet; i <p> <code>defer db.Close()</code> wird am Ende der Haupt -Goroutine ausgeführt, aber zu diesem Zeitpunkt können andere Goroutinen die Datenbankverbindung verwenden, was zu Programmenabstürzen oder Datenfehlern führt.</p><p> <strong>Fehlerdemonstration: Verbindung in jeder Goroutine schließen</strong></p><p> <code>db.Close()</code> in jede Goroutine zu setzen ist auch nicht die richtige Lösung:</p><pre class="brush:php;toolbar:false"> func querydb (db *db, i int) {
    Defer db.close () // Fehler: Jede Goroutine versucht, die Verbindung zu schließen // ... Datenbankabfrageoperation ...
}

Dies führt dazu, dass die Verbindung mehrmals geschlossen wird und einen Fehler geworfen hat.

Richtige Lösung 1: Verwenden Sie die Kellentruppe, um Goroutine zu synchronisieren

Durch die Verwendung sync.WaitGroup stellt sicher, dass alle Goroutinen ihre Arbeit vor dem Schließen der Verbindung abgeschlossen haben:

 var wg sync.waitgroup
DB: = Opendb ()
Defer db.close () // korrekt: Schließen Sie für i: = 0; i <p> Diese Methode zählt Goroutines nach <code>wg.Add(1)</code> und <code>wg.Done()</code> und <code>wg.Wait()</code> Blöcken, bis alle Goroutinen abgeschlossen sind und sicherstellen, dass die Verbindung zu einem sicheren Zeitpunkt geschlossen ist.</p><p> <strong>Richtige Lösung 2: Verwenden Sie globale Variablen und Hauptgoroutine -Kontrolle</strong></p><p> Ein weiterer einfacherer Weg besteht darin, die Datenbankverbindung als globale Variable zu definieren und sie einheitlich in der Haupt -Goroutine zu verwalten:</p><pre class="brush:php;toolbar:false"> var db *db

func main () {
    db = Opendb ()
    Defer db.close () // korrekt: Einheitlich in der Haupt -Goroutine schließen // ... Goroutine starten ...
}

func querydb (i int) {
    // ... Datenbankabfrageoperation ...
}

Auf diese Weise konzentriert sich deutlich die Verwaltung von Verbindungen auf der Haupt -Goroutine und vermeidet gleichzeitige Probleme mit dem Zugriff und zum Schließen.

Welche zu wählene Lösung zu wählen, hängt vom spezifischen Anwendungsszenario und der Codekomplexität ab. Die WaitGroup eignet sich für komplexere gleichzeitige Szenarien, während die globale variable Methode in einfachen Szenarien prägnanter und leicht zu verstehen ist. Der Schlüssel besteht darin, sicherzustellen, dass die Datenbankverbindung nur einmal geschlossen ist und schließlich alle Goroutinen abgeschlossen haben.

Das obige ist der detaillierte Inhalt vonWie können Datenbankverbindungen für mehrere gemeinsame Goroutine korrekt geschlossen werden?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!