Wie verhält sich Ticker.Stop() in Golang und wie können wir ordnungsgemäße Exits für Ticker-Goroutinen sicherstellen?

Ticker-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!