Comment éviter les blocages lors de l'utilisation de sync.WaitGroup avec une fonction externe ?

Utilisation optimale de sync.WaitGroup avec des fonctions externes

Problème :

Implémentation de la synchronisation. WaitGroup avec une fonction externe provoque un blocage lors de la tentative d'impression des nombres 1 à 11. Plus précisément, l'erreur se produit au niveau de la ligne wg.Wait().

Solution 1 (approche incorrecte) :

Définir wg.Add(1) au lieu de 2 est une solution incorrecte, car elle ne résout pas le problème fondamental.

Solution 2 (approche améliorée) :

Modifiez le code comme suit :

• Dans la fonction principale, passez l'adresse du sync.WaitGroup à la fonction Print à l'aide de &wg.
• Supprimez le wg paramètre de la signature de la fonction Print.

<code class="go">package main

import (
    "fmt"
    "sync"
)

func main() {    
    ch := make(chan int)

    var wg sync.WaitGroup
    wg.Add(2)    

    go Print(ch, &wg)

    go func() {  
        for i := 1; i <= 11; i++ {
            ch <- i
        }
        close(ch)
        wg.Done()
    }()          

    wg.Wait() //deadlock here
}                

func Print(ch <-chan int, wg *sync.WaitGroup) {
    for n := range ch { // reads from channel until it's closed
        fmt.Println(n)
    }            
    wg.Done()
}</code>

Explication :

Transmettre l'adresse de wg à Print garantit que la même instance WaitGroup est manipulée. La suppression de wg de la signature de la fonction Print élimine le besoin pour la fonction de connaître le WaitGroup externe.

Conclusion :

La deuxième solution est une approche plus robuste qui évite bloque et maintient l'indépendance de la fonction Print par rapport à wg.

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!