WaitGroup et utilisation des canaux dans le programme Golang
Ce programme Golang utilise sync.WaitGroup et les canaux pour obtenir une exécution goroutine et une collecte de données efficaces. Cependant, il rencontre un problème où le programme ne se ferme pas après avoir terminé ses tâches. Cet article approfondit le problème et propose une solution.
Le programme consiste à récupérer les cotations boursières d'une liste de symboles, puis à enregistrer les résultats dans des fichiers. Il utilise une combinaison de goroutines et de canaux pour exécuter le processus de récupération simultanément, avec un WaitGroup pour suivre l'achèvement de toutes les tâches. Cependant, le programme tombe dans une boucle infinie car le canal fetchedSymbols reste ouvert indéfiniment.
Pour résoudre ce problème, le programme doit fermer le canal fetchedSymbols une fois que toutes les goroutines ont terminé leurs tâches. Le WaitGroup, qui assure déjà le suivi de l'achèvement de la goroutine, peut être utilisé à cette fin. En ajoutant un wrapper go func() qui ferme le canal lorsque le WaitGroup atteint zéro, le problème est résolu.
La section de code modifiée est la suivante :
<code class="go">... go func() { wg.Wait() close(fetchedSymbols) }() for response := range fetchedSymbols { fmt.Println("fetched " + response) } ...</code>
Le go ajouté La routine func() attend que le WaitGroup atteigne zéro, indiquant que toutes les goroutines ont terminé leurs tâches. Il ferme ensuite le canal fetchedSymbols, permettant à la boucle de plage dans main de se terminer comme prévu et permettant au programme de terminer son exécution.
Ce programme amélioré utilise efficacement WaitGroup et les canaux pour l'exécution simultanée de goroutines et la récupération de données, et il se ferme. gracieusement après avoir terminé toutes les tâches nécessaires.
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!