Wie kann ich Kanäle in der Select-Anweisung von Go priorisieren?

Implementierung der Priorität in der Select-Anweisung von Go

Die Select-Anweisung von Go ermöglicht Goroutinen das Multiplexen auf mehreren Kanälen und verarbeitet Daten aus dem Kanal, der zuerst bereit wird . Allerdings wird die Priorisierung von Kanälen nicht nativ unterstützt. In diesem Artikel wird ein gängiges Programmierszenario untersucht, bei dem man bestimmten Kanälen innerhalb einer Select-Anweisung Vorrang vor anderen geben möchte.

Im bereitgestellten Beispiel sendet eine Goroutine Daten an zwei Kanäle, Out und Exit. Während beide Kanäle anfänglich leer sind, besteht die Absicht darin, Out so zu priorisieren, dass alle seine Werte verarbeitet werden, bevor Exit verarbeitet wird. Die Verwendung der standardmäßigen Select-Anweisung, wie in der Frage gezeigt, führt nicht zu diesem gewünschten Verhalten.

Um dieses Problem zu beheben, bietet Go eine elegante Lösung. Anstatt sich auf die integrierte Priorisierung von select zu verlassen, sollte der Kanal, der priorisiert werden soll (in diesem Fall Exit), nur für die Sender-Goroutine zugänglich sein. Wenn die Sender-Goroutine zum Beenden bereit ist, schließt sie den Kanal. Die Empfänger-Goroutine verwendet eine bereichsbasierte Schleife zum Durchlaufen des Kanals (für x := Bereichswerte) und verarbeitet weiterhin Daten, bis der Kanal geschlossen wird.

Die Implementierung dieser Lösung ergibt den folgenden Code:

package main

import (
    "fmt"
    "math/rand"
    "time"
)

var (
    produced  = 0
    processed = 0
)

func produceEndlessly(vals chan int, quit chan bool) {
    defer close(vals)
    for {
        select {
        case vals <- rand.Int():
            produced++
        case <-quit:
            return
        }
    }
}

func quitRandomly(quit chan bool) {
    d := time.Duration(rand.Int63n(5e9))
    fmt.Println("SLEEP", d)
    time.Sleep(d)
    fmt.Println("SEND QUIT")
    quit <- true
}

func main() {
    vals, quit := make(chan int, 10), make(chan bool)
    go produceEndlessly(vals, quit)
    go quitRandomly(quit)
    for x := range vals {
        fmt.Println(x)
        processed++
        time.Sleep(time.Duration(rand.Int63n(5e8)))
    }
    fmt.Println("Produced:", produced)
    fmt.Println("Processed:", processed)
}

In diesem aktualisierten Code wird der Beendigungskanal nur von der Absender-Goroutine kommuniziert. Dadurch wird sichergestellt, dass „Beenden“ erst ausgewählt wird, wenn der Absender zum Beenden bereit ist. Folglich erschöpft die Empfänger-Goroutine alle Daten von vals, bevor sie den Exit verarbeitet.

Das obige ist der detaillierte Inhalt vonWie kann ich Kanäle in der Select-Anweisung von Go priorisieren?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!