Wie kann ich Goroutine-Timeouts mithilfe von Kanälen in Go zuverlässig überschreiben?

Zeitüberschreitungen in Goroutinen mit Kanälen überschreiben

In Golang ist es bei der Verwendung von Goroutinen und Kanälen für asynchrone Aufgaben möglich, Zeitüberschreitungen anzugeben, um dies sicherzustellen Vorgänge bleiben nicht auf unbestimmte Zeit hängen. In bestimmten Szenarien wird der Timeout-Fall jedoch möglicherweise nicht wie erwartet ausgeführt.

Bedenken Sie den folgenden Codeausschnitt:

package main

import (
    "fmt"
    "time"
)

func main() {
    c1 := make(chan int, 1) // Buffered channel with capacity 1

    go func() {
        for {
            time.Sleep(1500 * time.Millisecond) // Sleep for 1.5 seconds
            c1 <- 10 // Send value to channel
        }
    }()

    go func() {
        for {
            select {
            case i := <-c1:
                fmt.Println(i)
            case <-time.After(2000 * time.Millisecond):
                fmt.Println("TIMEOUT") // Not executed
            }
        }
    }()

    fmt.Scanln() // Wait for user input
}

In diesem Code haben wir zwei Goroutinen: eine, die regelmäßig sendet einen Wert an einen gepufferten Kanal c1 und einen anderen, der aus c1 mit einem Timeout von 2 Sekunden auswählt. Der Timeout-Fall („TIMEOUT“) wird jedoch nie gedruckt.

Der Grund dafür liegt in der Natur der gepufferten Kanäle und der Art und Weise, wie Timeouts gehandhabt werden. In diesem Szenario füllt die Goroutine, die Werte an c1 sendet, den Kanal kontinuierlich alle 1,5 Sekunden auf. Daher erhält die Select-Anweisung in der zweiten Goroutine vor Ablauf des Timeouts immer einen Wert von c1.

Um dieses Problem zu beheben und sicherzustellen, dass der Timeout-Fall ausgeführt wird, müssen wir den Timeout-Kanal außerhalb erstellen die Auswahlschleife. Dies verhindert, dass es jedes Mal verworfen wird, wenn ein Wert von c1 empfangen wird:

timeout := time.After(2000 * time.Millisecond) // Create timeout channel only once
for {
    select {
    case i := <-c1:
        fmt.Println(i)
    case <-timeout:
        fmt.Println("TIMEOUT")
    }
}

Mit dieser Änderung wählt die Select-Anweisung weiterhin von c1 aus, aber wenn innerhalb des angegebenen Timeouts kein Wert empfangen wird, wird der Der Fall „TIMEOUT“ wird ausgeführt.

Das obige ist der detaillierte Inhalt vonWie kann ich Goroutine-Timeouts mithilfe von Kanälen in Go zuverlässig überschreiben?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!