Wie kann ich die Kontextaufhebung in der „select'-Anweisung von Go priorisieren?

Prioritätskontrolle in der Select-Anweisung von Go

In Go ermöglicht die Select-Anweisung eine asynchrone Kommunikation zwischen Goroutinen. Allerdings kann die Auswertungsreihenfolge von Fallblöcken manchmal zu unerwarteten Ergebnissen führen. Dieses Problem tritt auf, wenn versucht wird, die Behandlung eines bestimmten Falls zu priorisieren, z. B. das sofortige Verlassen einer Routine, wenn ein Kontext abgebrochen wird.

Beachten Sie den folgenden Code:

func sendRegularHeartbeats(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            return
        case <-time.After(1 * time.Second):
            sendHeartbeat()
        }
    }
}

Der Problem:
In diesem Code besteht die Absicht darin, die Behandlung des ctx.Done()-Falls gegenüber dem time.After()-Fall zu priorisieren. Aufgrund der nicht deterministischen Auswertungsreihenfolge von Go kann jedoch manchmal der Fall time.After() zuerst ausgewertet werden, was zur Übertragung eines Heartbeats führt, selbst wenn der Kontext abgebrochen wird.

Lösung:
Die vorgeschlagene Lösung in der akzeptierten Antwort schlägt das Hinzufügen einer verschachtelten Select-Anweisung mit einer nicht blockierenden Prüfung für ctx.Done() vor. Dies löst das Problem jedoch nicht vollständig, da die Wahrscheinlichkeit, dass der Heartbeat gesendet wird, hoch bleibt.

Ein effektiverer Ansatz besteht darin, die Behandlung des ctx.Done()-Falls zu priorisieren, indem ein Standardfall hinzugefügt wird die äußere Select-Anweisung:

func sendRegularHeartbeats(ctx context.Context) {
    ticker := time.NewTicker(time.Second)
    defer ticker.Stop()

    for {
        select {
        case <-ctx.Done():
            return
        default:
        }

        select {
        case <-ctx.Done():
            return
        case <-ticker.C:
            sendHeartbeat()
        }
    }
}

Dadurch wird sichergestellt, dass der Fall ctx.Done() zuerst in der äußeren Select-Anweisung ausgewertet wird, was ihm eine höhere Priorität verleiht. Wenn der Kontext abgebrochen wird, kehrt die Routine sofort zurück und es werden keine Heartbeats gesendet. Wenn der Fall time.After() zuerst eintrifft, wird er aufgrund des Standardfalls in der äußeren Select-Anweisung ignoriert.

Das obige ist der detaillierte Inhalt vonWie kann ich die Kontextaufhebung in der „select'-Anweisung von Go priorisieren?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!