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> <div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><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><div class="code" style="position:relative; padding:0px; margin:0px;"><div class="code" style="position:relative; padding:0px; margin:0px;"><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!
Une collection de commandes informatiques couramment utilisées
win10 se connecte à une imprimante partagée
Comment devenir un ami proche sur TikTok
Logiciel gratuit de récupération de données
Quelles sont les fonctions de création de sites Web ?
Comment représenter des nombres négatifs en binaire
python configurer les variables d'environnement
Comment ouvrir le fichier HTML WeChat
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
