Wie wirken sich verkettete Kanaloperationen in der „select'-Anweisung von Go auf blockierendes und nicht blockierendes Verhalten aus?

Verkettete Kanaloperationen in einem ausgewählten Fall: Blockierendes und nicht blockierendes Verhalten verstehen

Im Parallelitätsmodell von Go ist select ein leistungsstarkes Konstrukt, das es Goroutinen ermöglicht, auf mehrere zu warten Kanäle gleichzeitig. Beim Versuch, Kanaloperationen innerhalb eines ausgewählten Falls zu verketten, tritt jedoch eine häufige Gefahr auf, da dies zu unerwartetem Verhalten und potenziellen Deadlocks führen kann.

Bedenken Sie den folgenden Codeausschnitt, der versucht, zwei Kanäle (A und B) zu multiplexen ) mit unterschiedlichen zeitlichen Verzögerungen mithilfe von select:

func main() {
    ch := fanIn(talk("A", 10), talk("B", 1000))

    for i := 0; i < 10; i++ {
        fmt.Printf("%q\n", <-ch)
    }
}

In diesem Beispiel gibt talk einen Kanal zurück, der eine Folge von Nachrichten mit einer angegebenen Verzögerung sendet. fanIn ist eine Hilfsfunktion, die einen neuen Kanal erstellt, der mithilfe einer Select-Anweisung Werte von Input1 und Input2 empfängt.

Wenn die Select-Case-Anweisung wie folgt geändert wird:

select {
    case ch <- <-input1:
    case ch <- <-input2:
}

an unerwartetes Ergebnis auftritt. Einige Werte werden gelöscht, und schließlich kommt es zu einem Deadlock, da keine weiteren Werte vom Fan-In-Kanal empfangen werden.

Um dieses Verhalten zu verstehen, ist es wichtig, das Konzept der blockierenden und nicht blockierenden Vorgänge zu verstehen wählen. In einer SELECT-Anweisung ist jeweils nur ein Lese- oder Schreibvorgang für einen Kanal nicht blockierend. Alle anderen Vorgänge verhalten sich normal.

Im modifizierten Auswahlfall sind die Kanalempfangsvorgänge (<-input1 und <-input2) nicht blockierend. Dies bedeutet, dass sie sofort zurückkehren, auch wenn keine Werte zu empfangen sind.

Die Konsequenz dieses nicht blockierenden Verhaltens ist, dass bei erfolgreichem ersten Empfangsvorgang (z. B. von <-input1) gelesen wird und speichert den Wert. Der nachfolgende ch <--Vorgang kann jedoch immer noch blockiert sein, auch wenn er nicht blockierend ist. Diese Blockierung tritt auf, weil die Hauptfunktionsschleife den Wert aus dem kombinierten Kanal noch nicht verbraucht hat.

Dadurch gehen Werte verloren, was zum beobachteten Deadlock führt.

Stellen Sie sicher, dass das Verhalten korrekt ist dass nur der letzte Sende- oder Empfangsvorgang in einem ausgewählten Fall nicht blockierend ist. Mit anderen Worten: Verwenden Sie für Zwischenempfangsvorgänge den Zuweisungsoperator := anstelle des Pfeiloperators <-.

select {
    case t := <-input1:
        ch <- t
    case t := <-input2:
        ch <- t
}

Durch die Anpassung des Auswahlfalls auf diese Weise werden die Kanaloperationen und alle Werte ordnungsgemäß verkettet werden korrekt gesendet und empfangen, ohne dass das Risiko von Wertverlusten oder Deadlocks besteht.

Das obige ist der detaillierte Inhalt vonWie wirken sich verkettete Kanaloperationen in der „select'-Anweisung von Go auf blockierendes und nicht blockierendes Verhalten aus?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!