WaitGroup.Wait() et barrières mémoire : clarifier les garanties

En Go, le type WaitGroup est une primitive de synchronisation utilisée pour suivre les achèvement d'un ensemble de goroutines. La question se pose : lorsque wg.Wait() est appelé pour attendre la fin de toutes les goroutines, cela implique-t-il une barrière de mémoire ? Nous approfondirons cette question et explorerons la documentation officielle et les discussions associées.

La spécification et la documentation WaitGroup indiquent que WaitGroup.Wait bloque jusqu'à ce que le compteur atteigne zéro, indiquant que toutes les goroutines sont terminées. Cependant, il ne mentionne pas explicitement une barrière de mémoire.

Les discussions sur le forum Go ont fait allusion à l'existence d'une relation qui se produit avant entre wg.Wait() et wg.Done(). Une relation qui se produit avant garantit que toutes les opérations effectuées avant le premier événement (wg.Wait() dans ce cas) sont garanties d'être terminées avant toutes les opérations effectuées après le deuxième événement (wg.Done()).

Dans l'exemple de code donné, les goroutines vérifient si les éléments remplissent une condition et, si c'est le cas, définissent la variable de condition sur true. Sans barrière de mémoire, la variable de condition peut ne pas être mise à jour immédiatement, ce qui entraîne des conditions de concurrence potentielles.

Cependant, Ian Lance Taylor a confirmé qu'il existe effectivement une relation qui se produit avant entre wg.Wait( ) et wg.Done(). Cela signifie que toutes les mises à jour de la variable de condition effectuées avant d'appeler wg.Done() sont garanties d'être visibles par la routine principale après le retour de wg.Wait().

Bien que cela clarifie l'utilisation sûre de la variable de condition , il est important de noter que le code est toujours vulnérable aux conditions de concurrence si plusieurs éléments sont en cours de traitement. En effet, plusieurs goroutines pourraient potentiellement définir la variable de condition sur true simultanément, ce qui entraînerait une valeur incorrecte.

Par conséquent, bien que wg.Wait() fournisse une relation qui se produit avant, il est crucial d'utiliser une synchronisation supplémentaire. des mécanismes, tels que les mutex, lorsque plusieurs goroutines accèdent à des données partagées pour empêcher les courses aux données.