Pourquoi le passage d'un WaitGroup par valeur dans les canaux Go entraîne-t-il une impasse ?

Impasse dans le canal Go en raison du passage de références

Dans Go, les canaux sont un mécanisme de communication puissant, mais ils peuvent conduire à des blocages sinon utilisé correctement. Une impasse se produit lorsque deux goroutines ou plus s'attendent l'une l'autre pour terminer une opération, ce qui empêche aucune des goroutines de continuer.

Considérez le programme Go suivant :

<br>package main</p>
<p>import (</p>
<pre class="brush:php;toolbar:false">"fmt"
"sync"

)

func push(c chan int, wg sync.WaitGroup) {

for i := 0; i < 5; i++ {
    c <- i
}
wg.Done()

>

func pull(c chan int, wg sync.WaitGroup) {

for i := 0; i < 5; i++ {
    result, ok := <-c
    fmt.Println(result, ok)
}
wg.Done()

}

func main() {

var wg sync.WaitGroup
wg.Add(2)
c := make(chan int)

go push(c, wg)
go pull(c, wg)

wg.Wait()

>

Lorsque vous exécutez ce programme, il paniquera avec une erreur de blocage :

throw: all goroutines are asleep - deadlock!

Le problème réside dans la façon dont le WaitGroup est transmis aux goroutines . Dans Go, les structures sont transmises par valeur, ce qui signifie qu'une copie du WaitGroup est transmise à chaque goroutine. Lorsqu'une goroutine appelle Done sur sa copie, cela n'a aucun effet sur le WaitGroup d'origine créé dans la fonction principale.

Pour résoudre le blocage, le pointeur WaitGroup doit être passé à la place de la valeur. Voici le code corrigé :

<br>package main</p><p>import (</p><pre class="brush:php;toolbar:false">"fmt"
"sync"

)

func push(c chan int , wg *sync.WaitGroup) {

for i := 0; i < 5; i++ {
    c <- i
}
wg.Done()

}

func pull(c chan int, wg *sync.WaitGroup) {

for i := 0; i < 5; i++ {
    result, ok := <-c
    fmt.Println(result, ok)
}
wg.Done()

}

func main() {

var wg sync.WaitGroup
wg.Add(2)
c := make(chan int)

go push(c, &wg)
go pull(c, &wg)

wg.Wait()

}

En passant le pointeur WaitGroup au lieu de la valeur, les deux goroutines ont accès au même Instance WaitGroup. Lorsqu'une goroutine appelle Done, elle décrémente le décompte du WaitGroup d'origine, permettant à l'autre goroutine de continuer.

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!