Comment hiérarchiser les cas dans les instructions « select » de Go pour une exécution déterministe ?

Traitement de la priorité dans les instructions Go select

Lors de l'utilisation des instructions select dans Go, l'ordre d'évaluation des cas n'est généralement pas déterministe. Cependant, dans certains scénarios, nous devrons peut-être donner la priorité à l'exécution de certains cas.

Priorité avec annulation de contexte

Considérez le code suivant dans lequel nous souhaitons arrêter en douceur un émetteur de battement de coeur lorsque le contexte est annulé :

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

Cependant, lorsque le contexte est fermé immédiatement, le code peut toujours transmettre un battement de coeur avant le cas « Terminé » est exécuté.

Solution : priorité aux canaux d'assistance

Une approche pour résoudre ce problème consiste à utiliser un canal d'assistance pour prioriser le cas d'annulation de contexte :

func sendRegularHeartbeats(ctx context.Context) {
    done := make(chan struct{})
    go func() {
        <-ctx.Done()
        close(done)
    }()

    for {
        select {
        case <-done:
            return
        case <-time.After(1 * time.Second):
            sendHeartbeat()
        }
    }
}

Dans ce cas, le canal done garantit que le cas "ctx.Done()" est évalué en premier lorsque le contexte est annulé.

Considérations supplémentaires

Bien que cette solution améliore la priorité, elle n'élimine pas complètement la possibilité qu'un battement de cœur soit envoyé avant l'exécution du cas « Terminé ». Pour un arrêt véritablement synchronisé, envisagez d'utiliser des primitives de synchronisation telles que des variables atomiques ou des mutex pour garantir que la transmission du battement de cœur prend fin immédiatement après l'annulation du contexte.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!