Heim  >  Artikel  >  Backend-Entwicklung  >  Wie vermeide ich einen Deadlock beim Rangieren über einen gepufferten Kanal in GoLang?

Wie vermeide ich einen Deadlock beim Rangieren über einen gepufferten Kanal in GoLang?

Linda Hamilton
Linda HamiltonOriginal
2024-10-26 17:51:02134Durchsuche

How to Avoid Deadlock When Ranging Over a Buffered Channel in GoLang?

Deadlock in GoLang: Warum Range Over a Buffered Channel?

Bei der Verwendung gepufferter Kanäle in GoLang ist es wichtig, die Entstehung einer Deadlock-Situation zu vermeiden . Ein aktuelles Problem gab Anlass zu Bedenken hinsichtlich eines Deadlocks, der beim Versuch auftrat, über einen gepufferten Kanal zu wechseln, nachdem alle Goroutinen abgeschlossen waren.

Der bereitgestellte Code versucht, einen gepufferten Kanal mit einer Kapazität von 4 zu verwenden und 4 Goroutinen zu erzeugen, die Daten senden zum Kanal. Der Deadlock tritt jedoch auf, weil:

  • Die Kanalgröße zu klein ist, was dazu führt, dass blockierte Goroutinen darauf warten, in den gesamten Kanal zu schreiben.
  • Der Bereich über den Betrieb auf dem Kanal bleibt auf unbestimmte Zeit bestehen Warten auf das Eintreffen von Elementen, während keine Goroutinen mehr zum Schreiben übrig sind.

Lösung 1: Kanalgröße erweitern und nach Abschluss schließen

Um den Deadlock zu beheben, Der Kanal kann vergrößert und geschlossen werden, nachdem alle Goroutinen abgeschlossen sind:

<code class="go">ch := make(chan []int, 5)
...
wg.Wait()
close(ch)</code>

Dadurch entfallen jedoch die Vorteile des Pipelinings, da das Drucken verhindert wird, bis alle Aufgaben abgeschlossen sind.

Lösung 2: Signalabschluss aus der Druckroutine heraus

Um tatsächliches Pipelining zu ermöglichen, kann die Funktion Done() innerhalb der Druckroutine aufgerufen werden:

<code class="go">func main() {
    ch := make(chan []int, 4)
    ...
    go func() {
        for c := range ch {
            fmt.Printf("c is %v\n", c)
            wg.Done()
        }
    }()
    ...
}</code>

Dieser Ansatz stellt sicher dass die Funktion Done() erst aufgerufen wird, nachdem jedes Element gedruckt wurde, was effektiv den Abschluss jeder Goroutine signalisiert.

Das obige ist der detaillierte Inhalt vonWie vermeide ich einen Deadlock beim Rangieren über einen gepufferten Kanal in GoLang?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn