Pourquoi mon programme Go se bloque-t-il même lorsque tous les Goroutines sont terminés ? Un guide sur sync.WaitGroup et le blocage de canaux.

Confusion à propos de la sortie de Goroutine : dévoilement du mystère de sync.WaitGroup et du blocage de canaux

Dans Go, la gestion de la concurrence avec sync.WaitGroup et les canaux est une pratique courante. Cependant, pour les débutants, il peut être déroutant qu'un programme se bloque alors qu'il répond aux attentes d'achèvement des goroutines. Examinons un cas spécifique et déterminons le problème sous-jacent.

Le problème

Un développeur a implémenté un programme utilisant sync.WaitGroup et un canal (fetchedSymbols) pour récupérer simultanément une liste de cotations boursières. Pendant que le programme attendait la fin des goroutines, il a refusé de se terminer.

Comprendre le problème

La racine du problème réside dans l'omission de fermer le canal fetchedSymbols. Lors d'une itération sur ce canal dans la fonction principale, le programme devient indéfiniment bloqué. Dans ce cas, la fermeture du canal doit être initiée à la fin de toutes les goroutines.

Solution

Pour garantir une exécution fluide du programme, le développeur a introduit une goroutine d'assistance qui surveille le sync.WaitGroup et déclenche la fermeture de fetchedSymbols une fois que toutes les goroutines ont terminé leurs tâches. Cela a éliminé le comportement de blocage et a permis au programme de se fermer correctement.

Mise en œuvre

<code class="go">go func() {
    wg.Wait()
    close(fetchedSymbols)
}()

for response := range fetchedSymbols {
    fmt.Println("fetched " + response)
}</code>

En implémentant cette solution, le programme se ferme désormais en douceur après avoir téléchargé avec succès toutes les cotations boursières, en utilisant efficacement la concurrence de Go. fonctionnalités.

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!