Warum führt eine Kombination aus „sync.WaitGroup“ und Kanal zu einem Deadlock in Go?

Verstehen von Deadlocks bei der Verwendung von sync.WaitGroup und Kanälen in Go

Entwickler haben häufig Probleme damit, dass ihre Go-Anwendungen bei Verwendung von sync.WaitGroup nie beendet werden und Kanäle. Dieser Artikel untersucht die Gründe für solche Deadlocks und bietet eine Lösung mithilfe der WaitGroup.

Betrachten Sie den bereitgestellten Beispielcode:

package main

import (
    "fmt"
    "io"
    "log"
    "net/http"
    "os"
    "sync"
)

var symbols = []string{
    "ASSA-B.ST",
    "ELUX-B.ST",
    "HM-B.ST",
}

func main() {

    fmt.Println("fetching quotes...")

    fetchedSymbols := make(chan string)
    var wg sync.WaitGroup
    wg.Add(len(symbols))

    for _, symbol := range symbols {
        go fetchSymbol(symbol, &wg, fetchedSymbols)
    }

    for response := range fetchedSymbols {
        fmt.Println("fetched " + response)
    }

    wg.Wait()

    fmt.Println("done")

}

func fetchSymbol(symbol string, wg *sync.WaitGroup, c chan<- string) {
    defer wg.Done()
    resp, err := http.Get("http://ichart.yahoo.com/table.csv?s=" + symbol + "&amp;a=0&amp;b=1&amp;c=2000")
    defer resp.Body.Close()

    if err != nil {
        log.Fatal(err)
    }

    out, err := os.Create("./stock-quotes/" + symbol + ".csv")
    defer out.Close()

    if err != nil {
        log.Fatal(err)
    }

    io.Copy(out, resp.Body)
    c <- symbol
}

In diesem Code blockiert die Bereichsschleife über fetchedSymbols den Hauptcode Funktion auf unbestimmte Zeit. Warum? Weil der fetchedSymbols-Kanal niemals geschlossen wird. Um diesen Deadlock zu beheben, kann die WaitGroup verwendet werden, um zu signalisieren, wann der Kanal geschlossen werden soll:

...
go func() {
    wg.Wait()
    close(fetchedSymbols)
}()

for response := range fetchedSymbols {
    fmt.Println("fetched " + response)
}

...

Da die WaitGroup bereits verfolgt, wann alle Goroutinen abgeschlossen sind, kann sie genutzt werden, um das Schließen des fetchedSymbols-Kanals auszulösen , um sicherzustellen, dass die Bereichsschleife ordnungsgemäß beendet wird.

Das obige ist der detaillierte Inhalt vonWarum führt eine Kombination aus „sync.WaitGroup“ und Kanal zu einem Deadlock in Go?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!