Wie kann ich die Kontextaufhebung in den „select'-Anweisungen von Go priorisieren?

Adressierung der Priorität in Go-Select-Anweisungen

In bestimmten Szenarien ist es entscheidend, die Ausführung von Case-Blöcken in einer Select-Anweisung zu priorisieren. Insbesondere bei der Arbeit mit Kontexten, die Abbruchereignisse darstellen, ist es unbedingt erforderlich, dass das Signal „Fertig“ umgehend verarbeitet wird, um eine ordnungsgemäße Beendigung des Programms sicherzustellen.

Beachten Sie den folgenden Code:

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

Diese Routine wird ausgeführt in einer separaten Goroutine und sendet in regelmäßigen Abständen Herzschläge. Wenn der Kontext jedoch abgebrochen wird, sendet der Code gelegentlich immer noch einen Heartbeat, bevor der Fall „Fertig“ verarbeitet wird.

Das Standardverhalten der SELECT-Anweisung garantiert nicht die Reihenfolge der Fallauswertung, sodass eine Durchsetzung erforderlich ist die gewünschte Priorität explizit angeben. Ein unvollkommener Ansatz besteht darin, vor der Heartbeat-Übertragung zu prüfen, ob ein geschlossener Kontext vorliegt.

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

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

        // Second select
        select {
        case <-ctx.Done():
            return
        case <-ticker.C:
            // Check if context is done again in case a concurrent Done event arrived
            select {
            case <-ctx.Done():
            default:
            }
            sendHeartbeat()
        }
    }
}

Während diese Methode dem Done-Signal Priorität einräumt, führt sie eine zusätzliche Race-Bedingung ein. Wenn ein Done-Ereignis und ein Ticker-Ereignis gleichzeitig auftreten, ist es möglich, dass die Heartbeat-Übertragung erfolgt, bevor das Done-Ereignis behandelt wird.

Leider gibt es derzeit in Go keine perfekte Lösung für dieses Problem. Die bereitgestellte Problemumgehung bietet jedoch eine Verbesserung gegenüber dem ursprünglichen Code, indem sie eine verschachtelte Select-Anweisung einführt, um die Wahrscheinlichkeit solcher Race Conditions zu minimieren.

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