Comment signaler l'arrêt d'une routine Go sans bloquer ?

Signaler l'arrêt d'une routine Go

Dans ce scénario, une routine Go doit recevoir l'ordre de cesser son fonctionnement. Le principal défi réside dans la réalisation de cette signalisation sans introduire de comportement de blocage.

La solution proposée consiste à utiliser un canal secondaire. Cependant, l'utilisation conventionnelle du canal entraînerait un blocage si la routine go tente de recevoir un signal de ce canal tout en traitant activement les données.

Utilisation d'un cas de sélection

Pour éviter le blocage, le code peut exploiter un cas sélectionné avec une clause par défaut. Cela permet à la routine go de continuer à traiter les données jusqu'à ce qu'un signal soit reçu du canal secondaire :

<code class="go">go func() {
    for {
        fmt.Println("working")
        time.Sleep(1 * time.Second)
        select {
        case <-tooLate:
            fmt.Println("stopped")
            return
        case proCh <- "processed": //this why it won't block the goroutine if the timer expirerd.
        default: // adding default will make it not block
        }
        fmt.Println("done here")
    }
}()</code>

En utilisant la clause par défaut, la routine go peut éviter le blocage même lorsque le minuteur expire.

Utiliser un sync.Cond

Une autre approche consiste à utiliser un sync.Cond au lieu d'un canal. Une variable de condition fournit un moyen d'attendre et de signaler entre les goroutines.

Conclusion

Avec un canal secondaire avec une clause par défaut ou une sync.Cond, vous pouvez efficacement signaler à une routine go d'arrêter courir sans recourir à un comportement de blocage.

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!