Dans un programme Golang, les canaux facilitent la communication entre les goroutines. Cependant, une mauvaise utilisation des canaux peut entraîner des blocages, comme le démontre le code ci-dessous :
<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() // Block the main thread until goroutines complete
}
Lors de l'exécution de ce programme, vous pourriez rencontrer l'erreur suivante :
fatal error: all goroutines are asleep - deadlock!
Pour comprendre pourquoi ce blocage se produit, examinons le code :
Le problème réside dans la façon dont le WaitGroup est transmis aux goroutines. Lorsqu'une valeur est transmise sans esperluette (&), elle est transmise par valeur et non par référence. Dans ce cas, une copie du WaitGroup est créée pour chaque goroutine.
Par conséquent, lorsque chaque goroutine appelle wg.Done(), elle modifie sa copie locale du WaitGroup. Étant donné que le thread principal attend que wg indique que toutes les goroutines sont terminées, il attend indéfiniment car aucune des goroutines ne met à jour le WaitGroup d'origine. Cela conduit à une impasse.
Pour résoudre ce problème, nous devons transmettre le WaitGroup par référence. Cela garantit que les deux goroutines modifient la même instance du WaitGroup et signalent correctement leur achèvement au thread principal.
Voici une version révisée du code avec la correction :
<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) // Pass the WaitGroup by reference using the ampersand go pull(c, &wg) // Pass the WaitGroup by reference using the ampersand wg.Wait()
}
En passant le WaitGroup par référence, nous nous assurons que le thread principal peut déterminer correctement quand les deux goroutines ont terminé leurs tâches, évitant ainsi l'impasse.
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!
Quelles sont les méthodes de détection des vulnérabilités ASP ?
Comment agrandir Webstorm
La différence entre * et & en langage C
Téléchargement de l'application Yiou Exchange
Comment créer un projet HTML avec vscode
Quels sont les avantages et les inconvénients de la décentralisation
Comment connecter PHP à la base de données mssql
Échec de la routine d'initialisation de la bibliothèque de liens dynamiques
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
