


Wie verhält sich Ticker.Stop() in Golang und wie können wir ordnungsgemäße Exits für Ticker-Goroutinen sicherstellen?
Nov 09, 2024 am 04:38 AMTicker-Stop-Verhalten in Golang: Umgang mit ordnungsgemäßen Exits
In Golang wird ein Ticker-Kanal häufig zum Erstellen eines regelmäßig auftretenden Ereignisses verwendet. Es ist jedoch wichtig zu verstehen, wie sich Stop() verhält, um eine ordnungsgemäße Kanalbehandlung sicherzustellen.
Beachten Sie den folgenden Codeausschnitt:
ticker := time.NewTicker(1 * time.Second) go func() { for _ = range ticker.C { log.Println("tick") } log.Println("stopped") }() time.Sleep(3 * time.Second) log.Println("stopping ticker") ticker.Stop() time.Sleep(3 * time.Second)
Wenn ticker.Stop() aufgerufen wird, wird der Ticker aufgerufen pausiert, aber der Kanal wird nicht automatisch geschlossen. Das bedeutet, dass die Goroutine pausiert, aber nicht beendet wird. Das Ausführen des obigen Codes erzeugt die folgende Ausgabe:
2013/07/22 14:26:53 tick 2013/07/22 14:26:54 tick 2013/07/22 14:26:55 tick 2013/07/22 14:26:55 stopping ticker
Daher bleibt die Goroutine blockiert und wartet auf weitere Tickerereignisse.
Um dieses Problem zu beheben, kann man einen zweiten Kanal verwenden, um das zu kommunizieren Stop-Anfrage an den Ticker goroutine. Hier ist ein Beispiel:
package main import ( "log" "sync" "time" ) type Ticker struct { sync.Mutex ticker *time.Ticker stop chan struct{} } func (t *Ticker) Start(d time.Duration) { t.Lock() defer t.Unlock() if t.ticker != nil { t.ticker.Stop() } t.ticker = time.NewTicker(d) t.stop = make(chan struct{}) go func() { for { select { case <-t.ticker.C: log.Println("tick") case <-t.stop: return } } }() } func (t *Ticker) Stop() { t.Lock() defer t.Unlock() if t.stop != nil { close(t.stop) t.ticker.Stop() } } func main() { t := Ticker{} t.Start(1 * time.Second) time.Sleep(3 * time.Second) log.Println("stopping ticker") t.Stop() time.Sleep(3 * time.Second) }
Durch die Verwendung eines separaten Stoppkanals können wir sicherstellen, dass die Ticker-Goroutine ordnungsgemäß beendet wird, wenn die Ticker.Stop()-Methode aufgerufen wird.
Das obige ist der detaillierte Inhalt vonWie verhält sich Ticker.Stop() in Golang und wie können wir ordnungsgemäße Exits für Ticker-Goroutinen sicherstellen?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Heißer Artikel

Hot-Tools-Tags

Heißer Artikel

Heiße Artikel -Tags

Notepad++7.3.1
Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version
Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1
Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6
Visuelle Webentwicklungstools

SublimeText3 Mac-Version
Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Heiße Themen

GO Language Pack Import: Was ist der Unterschied zwischen Unterstrich und ohne Unterstrich?

Wie kann ich kurzfristige Informationsübertragung zwischen Seiten im BeEGO-Framework implementieren?

Wie schreibe ich Scheinobjekte und Stubs zum Testen in Go?

Wie kann ich Tracing -Tools verwenden, um den Ausführungsfluss meiner GO -Anwendungen zu verstehen?

Wie konvertieren Sie die Liste der MySQL -Abfrageergebnisse in eine benutzerdefinierte Struktur -Slice in Go -Sprache?

Wie kann ich benutzerdefinierte Typ -Einschränkungen für Generika in Go definieren?

Wie schreibe ich Dateien in Go Language bequem?

Wie kann ich Linter und statische Analyse -Tools verwenden, um die Qualität und Wartbarkeit meines GO -Codes zu verbessern?
