Pourquoi la transmission de valeurs au lieu de pointeurs provoque-t-elle un blocage dans les canaux Go ?

Erreur de blocage dans le canal Go

Dans Go, les canaux fournissent un moyen de communication entre les goroutines. Cependant, une mauvaise utilisation des canaux peut conduire à des blocages, où les goroutines sont bloquées indéfiniment.

Une cause fréquente de blocages avec les canaux est la transmission de types de valeur au lieu de pointeurs dans les fonctions goroutine. En effet, Go transmet les types de valeur par valeur, ce qui signifie qu'une copie de la valeur est créée.

Considérez cet exemple :

<code class="go">import (
    "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()
}</code>

L'exécution du programme entraîne une erreur de blocage :

    0 true
    1 true
    2 true
    3 true
    4 true
    throw: all goroutines are asleep - deadlock!

Le blocage se produit car le WaitGroup est transmis aux fonctions push et pull en tant que valeur. Lorsque le WaitGroup est mis à jour dans l'un des goroutines, les modifications ne sont pas reflétées dans l'autre goroutine car il a une copie de la valeur.

Pour résoudre le blocage, nous devons passer le WaitGroup comme pointeur, qui garantit que les deux goroutines fonctionnent sur la même instance du WaitGroup.

Voici la version corrigée du code :

<code class="go">import (
    "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()
}</code>

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!