Maison > développement back-end > Golang > Comment hiérarchiser les cas dans les instructions « select » de Go pour une exécution déterministe ?

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

Patricia Arquette
Libérer: 2024-12-06 09:53:11
original
660 Les gens l'ont consulté

How to Prioritize Cases in Go's `select` Statements for Deterministic Execution?

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()
        }
    }
}
Copier après la connexion

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()
        }
    }
}
Copier après la connexion

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!

source:php.cn
Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn
Derniers articles par auteur
Tutoriels populaires
Plus>
Derniers téléchargements
Plus>
effets Web
Code source du site Web
Matériel du site Web
Modèle frontal