Wie kann ich Kanäle in der „select'-Anweisung von Go priorisieren?

Priorität in der Go-Select-Anweisung

Beim Arbeiten mit mehreren Kanälen mithilfe der Go-Select-Anweisung ist die Reihenfolge, in der Kanäle behandelt werden, nicht garantiert. Um einen Kanal gegenüber einem anderen zu priorisieren, steht eine Problemumgehung zur Verfügung.

Problemstellung

Im folgenden Codeausschnitt besteht das Ziel darin, sicherzustellen, dass alle Werte im Ausgangskanal vorhanden sind werden vor dem Exit-Kanal verarbeitet:

package main

import "fmt"

func sender(out chan int, exit chan bool){
    for i := 1; i <= 10; i++ {
        out <- i
    }
    exit <- true
}

func main(){
    out := make(chan int, 10)
    exit := make(chan bool)

    go sender(out, exit)

    L:
    for {
        select {
            case i := <-out:
                fmt.Printf("Value: %d\n", i)
            case <-exit:
                fmt.Println("Exiting")
                break L
        }
    }
    fmt.Println("Did we get all 10? Most likely not")
}

Die Verwendung der Select-Anweisung bietet jedoch keine Priorität für einen Kanal gegenüber dem andere.

Lösung: Native Language Support

Go unterstützt nativ die Priorisierung von Kanälen in einer Select-Anweisung, indem die Sichtbarkeit des „Quit“-Kanals nur auf den Produzenten beschränkt wird. Wenn der Produzent beschließt, aufzuhören, schließt er den Kanal. Der Verbraucher wird nur beendet, wenn der Kanal leer und geschlossen ist.

package main

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

var (
    produced  = 0
    processed = 0
)

func produceEndlessly(out chan int, quit chan bool) {
    defer close(out)
    for {
        select {
        case <-quit:
            fmt.Println("RECV QUIT")
            return
        default:
            out <- rand.Int()
            time.Sleep(time.Duration(rand.Int63n(5e6)))
            produced++
        }
    }
}

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 Beispiel ist der Beendigungskanal nur für die Produzentenfunktion (produceEndlessly) sichtbar. Der Produzent beschließt zufällig, nach einer gewissen Verzögerung aufzuhören. Die Verbraucherfunktion (Hauptfunktion) iteriert über den Vals-Kanal, bis er geschlossen und leer ist. Durch die Priorisierung der „Quit“-Nachricht des Produzenten werden alle Werte im Vals-Kanal verarbeitet, bevor das Programm beendet wird.

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!