Comment éviter les blocages lors de l'utilisation de Goroutines pour le traitement parallèle et la collecte des résultats ?

Comprendre les goroutines pour le traitement parallèle et la collecte des résultats

Contexte

Votre objectif est d'utiliser les goroutines dans Go pour traiter les éléments en parallèle, en collectant leurs résultats en tranche. Cependant, vous avez rencontré une erreur de blocage déroutante : "toutes les goroutines sont endormies - blocage !"

Solution

L'erreur provient de deux problèmes dans votre code :

1. Collecte différée : Vous attendez que toutes les goroutines soient terminées avant de collecter les résultats, ce qui est incorrect.
2. Fermeture prématurée de la chaîne : La chaîne est fermée après la collecte des résultats la boucle se termine, mettant fin prématurément à l'itération.

Code révisé

Pour corriger ces problèmes, introduisez une goroutine qui ferme le canal de manière asynchrone lorsque les travailleurs ont terminé :

for i, line := range contents {
  wg.Add(1)
  go newSample(line, *replicatePtr, *timePtr, sampleChan, &wg)
}

go func() {
  wg.Wait()
  close(sampleChan)
}()

for s := range sampleChan {
  ..
}

Explication

• Fermeture de canal asynchrone : La goroutine anonyme ferme le canal une fois que tous les travailleurs ont terminé, évitant ainsi la fin prématurée de la boucle.
• Recommandation de style : Envisagez d'utiliser une fonction d'assistance synchrone (newSample) qui ne prend pas en charge le canal et le groupe d'attente, ce qui simplifie le code et améliore la testabilité.

Refactoring pour l'efficacité

Si vous Si vous avez besoin d'un nombre fixe de nœuds de calcul pour une efficacité optimale, refactorisez le code comme suit :

for i, line := range contents {
  wg.Add(1)
  go func(line string) {
    defer wg.Done()
    sampleChan <- newSample(line, *replicatePtr, *timePtr)
  }(line)
}

Cela maintient les primitives de concurrence ensemble et simplifie la refactorisation pour différents modèles de concurrence.

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!