Wie stellen wir sicher, dass der abgebrochene Kontext dazu führt, dass die Goroutine beendet wird?

PHP-Editor Zimo zeigt Ihnen, wie Sie sicherstellen können, dass das Abbrechen des Kontexts zum Beenden der Goroutine führt. Wenn wir Goroutine verwenden, müssen wir es manchmal abbrechen, wenn eine bestimmte Bedingung erfüllt ist, um unnötige Berechnungen und Ressourcenverschwendung zu vermeiden. Um sicherzustellen, dass die Goroutine korrekt beendet wird, können wir den vom Kontextpaket bereitgestellten Mechanismus verwenden. Das Kontextpaket bietet eine Möglichkeit, Anfragen zwischen Goroutinen weiterzuleiten und diese Anfragen bei Bedarf abzubrechen. Durch die ordnungsgemäße Verwendung des Kontextpakets können wir sicherstellen, dass die Goroutine korrekt beendet wird, wenn der Kontext abgebrochen wird, und so Ressourcenlecks und andere potenzielle Probleme vermeiden. Im Folgenden wird detailliert beschrieben, wie Sie das Kontextpaket verwenden, um dieses Ziel zu erreichen.

Frageninhalt

Angenommen, Folgendes passiert:

• Wir haben die folgende consumer Funktion, die in einer Goroutine ausgeführt wird.

• Eine weitere Goroutine läuft intchan 通道上毫无延迟地发送整数。换句话说，在 for 循环的每次迭代中，intchan beide mit einem empfangsbereiten Wert.

• Die Goroutine, die die consumer goroutine 的 goroutine 已取消传递到 consumer 的上下文。因此，ctx.done() Goroutine gestartet hat, hat den an

  übergebenen Kontext abgebrochen. Daher muss auch der Kanal ctx.done() einen Wert empfangen.

Frage:

In diesem Fall sind beide Fälle der SELECT-Anweisung zur Ausführung bereit.
• selectJe nach Go-Reise wählt
zufällig einen Fall aus, da beide betriebsbereit sind.
• select 不会继续选择 <- intchan 案例？如果 <- c​​tx.done() 案例在 for 循环的每次迭代中都准备就绪，我们如何知道 <- c​​tx.done()Wie kann sichergestellt werden, dass
nicht weiterhin der Fall <- intchan gewählt wird? Wenn der <- c​​tx.done()-Fall bei jeder Iteration der for-Schleife bereit ist, woher wissen wir dann, dass <- c​​tx.done() Fälle werden schließlich ausgewählt?

func consumer(ctx context.context, intchan chan int) {
    for {
        select {
        case <-ctx.done():
            return
        case i := <-intchan:
            foo(i)
        }
    }
}

consumerIch habe versucht, die Funktion consumer 和 producer im Programm unten zu verwenden. Bei mehreren Durchläufen dieses Programms scheinen die Goroutinen

und producer immer zu terminieren.

<-ctx.done()Warum kommt es nicht zu einem

Lauf, bei dem der Fall nie ausgeführt wird?

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func main() {

    ctx, cancelFunc := context.WithCancel(context.Background())

    var wg sync.WaitGroup
    wg.Add(2) // add 2, because we spawn 2 goroutines

    Producer(ctx, &wg)

    fmt.Println(time.Now())
    time.Sleep(time.Second * 5) // cancel the context after 5 seconds

    cancelFunc()
    fmt.Println("CANCELLED")

    wg.Wait() // wait till both producer and consumer goroutines terminate
    fmt.Println(time.Now())

}

func Producer(ctx context.Context, wg *sync.WaitGroup) {
    intChan := make(chan int)

    go Consumer(ctx, intChan, wg)

    go func() {
        defer wg.Done()
        for {
            select {
            case <-ctx.Done():
                return
            case intChan <- 1:
            }
        }
    }()

}

func Consumer(ctx context.Context, intChan chan int, wg *sync.WaitGroup) {
    defer wg.Done()

    for {
        select {
        case <-ctx.Done():
            return
        case _ = <-intChan:
        }
    }
}

Lösung

ctx.err()Keine Garantie. Der einfachste Weg, die Beendigung zu gewährleisten, besteht darin, mit

nach Fehlern außerhalb der select-Anweisung zu suchen. Es kommt auch häufig vor, dass Fehler an den Code zurückgegeben werden, der den Kontext übergibt. Ich würde die Verbraucherfunktion so schreiben: 🎜

func Consumer(ctx context.Context, intChan chan int) error {
    for ctx.Err() == nil {
        select {
        case <-ctx.Done():
        case i := <-intChan:
            foo(i)
        }
    }
    return ctx.Err()
}

Das obige ist der detaillierte Inhalt vonWie stellen wir sicher, dass der abgebrochene Kontext dazu führt, dass die Goroutine beendet wird?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!