Gewährleistung der Goroutinen-Persistenz trotz Abstürzen
In gleichzeitigen Go-Programmen laufen oft mehrere Goroutinen gleichzeitig, wobei jede unterschiedliche Aufgaben ausführt. Es ist jedoch von entscheidender Bedeutung, das Problem der Behandlung von Goroutine-Fehlern anzugehen und sicherzustellen, dass andere Goroutinen auch dann weiterlaufen, wenn eine davon abstürzt.
Stellen Sie sich ein Programm mit zwei Goroutinen vor: queue.ConsumeAndDoSomething() verbraucht eine Warteschlange und api.StartServer () führt eine API aus. Wenn queue.ConsumeAndDoSomething() fehlschlägt, sollte der API-Server im Idealfall davon nicht betroffen sein und umgekehrt.
Ein Ansatz zum Erreichen dieser Persistenz ist die integrierte Funktion „recover()“ und verzögerte Funktionen. Die Funktion „recover()“ kann Panikattacken abfangen und eine Bereinigungsroutine ausführen, während verzögerte Funktionen automatisch am Ende der umgebenden Funktion ausgeführt werden.
So verwenden Sie „recover()“ und verzögerte Funktionen zum Schutz vor Goroutine-Abstürzen:
func protect(f func()) { defer func() { if err := recover(); err != nil { log.Printf("Recovered: %v", err) } }() f() }
Diese Hilfsfunktion, protected(), verpackt die bereitgestellte Funktion (f) in eine verzögerte Funktion, die etwaige Paniken behandelt. Die verzögerte Funktion wird ausgeführt, bevor f zurückkehrt, unabhängig davon, ob eine Panik auftritt oder nicht.
Um Protect() zu verwenden, übergeben Sie einfach die Goroutine-Funktion als Argument:
func main() { go protect(queue.ConsumeAndDoSomething) go protect(api.StartServer) for { time.Sleep(time.Second) fmt.Println("tick") } }
Mit diesem Mechanismus Wenn bei queue.ConsumeAndDoSomething() oder api.StartServer() eine Panik auftritt, wird diese von der verzögerten Funktion abgefangen und bereinigt, ohne dass das Programm abstürzt. Die andere Goroutine läuft wie erwartet weiter.
Das obige ist der detaillierte Inhalt vonWie kann die „recover()'-Funktion von Go die Goroutine-Persistenz angesichts von Abstürzen sicherstellen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!