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!
La différence entre un téléphone de remplacement officiel et un téléphone neuf
Que faire si l'ordinateur n'a pas de son
Quelles sont les méthodes d'analyse des données ?
localhost8080 ne peut pas accéder à la solution
Comment ouvrir le fichier iso
Solution à l'autorisation refusée
Introduction au code d'effets spéciaux javascript
Comment changer le mot de passe dans MySQL
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
