Kann ich die Beendigung einer Goroutine erzwingen, ohne darauf zu warten, dass sie zurückkehrt?

Question

Lassen Sie mich ein Beispiel verwenden:

func WaitForStringOrTimeout() (string, error) { 
    my_channel := make(chan string) 
    go WaitForString(my_channel) 

    select { 
    case found_string := <-my_channel: 
    return found_string, nil 
    case <-time.After(15 * time.Minute): 
    return nil, errors.New("Timed out waiting for string") 
    } 
} 

In diesem einfachen Beispiel, ich habe eine Funktion WaitForString die Blöcke für eine Weile und schließlich einen String zurückgeben kann. Ich möchte WaitForString mit diesem Code umbrechen, der entweder die gleiche Zeichenfolge zurückgibt oder ein Zeitlimit mit einem Fehler anzeigt.

Wenn eine Zeichenfolge schnell gefunden wird, ist es noch ein goroutine mit einer irgendwo schlafen Anweisung 15 Minuten laufen oder dieser Müll irgendwie gesammelt?

Wenn die Zeitüberschreitung auftritt und eine Zeichenfolge nie gefunden wird, gibt es noch eine goroutine, die WaitForString ausführt, obwohl es keine anderen Routinen gibt, die ihre Ausgabe beobachten können? Was passiert, wenn WaitForString viel Speicher zuweist, aber nie zurückkehrt?

Gibt es irgendeine Weise, die ich WaitForString machen kann() Kenntnis von der Timeout auftritt und aufgeben?

Answer 1

Im Allgemeinen keine gibt es keine Möglichkeit, eine andere goroutine zu stoppen. Es gibt eine runtime.Goexit Funktion, die verwendet werden kann, um das Beenden der aktuellen Goroutine zu veranlassen (selbst wenn sie von einem tiefen Aufrufrahmen aufgerufen wird), aber nichts, um zu bewirken, dass andere Goroutinen beendet werden. Für den spezifischen Fall des Moduls time gibt es keine separate Goroutine, die jeden Timer oder Ticker behandelt: stattdessen werden Timer zentral von der Laufzeit verwaltet, so dass sie erkennen kann, wann sie als nächstes aufwachen muss.

Während keine goroutine gibt es rumhängen, der Kanal und eine kleine Buchhaltung Struktur wird für die 15 Minuten bleiben, um.

Wenn dies ein Problem ist, verwenden Sie time.NewTimer anstelle von time.After, und stoppen Sie den Timer manuell, wenn Sie zurückkehren. Zum Beispiel:

t := time.NewTimer(15 * time.Minute) 
defer t.Stop() 
select { 
case found_string := <-my_channel: 
    return found_string, nil 
case <-t.C: 
    return nil, errors.New("Timed out waiting for string") 
} 

time.After ist wirklich nützlich für die genaue periodisches Verhalten, während time.NewTimer für einfache Timeouts gut funktioniert.