Deadlock zwischen goroutines

Question

Ich bin neu in Go. Wenn ich die zweite Goroutine auskommentiere, gibt es einen fatalen Fehler. Ich verstehe nicht, was diesen Fehler verursacht. Kannst du es mir erklären?

package main 

import (
    "fmt" 
    "time" 
) 

func main() { 
    ch := make(chan int) 
    go func() { 
     for i := 0; i < 10; i++ { 
      ch <- i 
     } 
    }() 
    // go func() { 
     for { 
      if num, ok := <-ch; !ok { 
       break 
      } else { 
       fmt.Printf("%d\n", num) 
      } 
     } 
    // }() 
    time.Sleep(2 * time.Second) 
    close(ch) 
} 

Dieser druckt den folgenden Code:

0 
1 
2 
3 
4 
5 
6 
7 
8 
9 
fatal error: all goroutines are asleep - deadlock! 

goroutine 1 [chan receive]: 
main.main() 
    /tmp/sandbox169127128/main.go:17 +0xa0 

Program exited. 

Answer 1

für die empfangende Schleifenblöcke auf von ch empfangen, nachdem alle Werte von der Sende goroutine empfängt. Die Laufzeit erkennt, dass das Programm blockiert und in Panik ist.

Die Fehlerbehebung wird der Kanal nach dem Senden aller Werte schließen:

go func() { 
    for i := 0; i < 10; i++ { 
     ch <- i 
    } 
    close(ch) 
}() 

auf dem geschlossenen Kanal Empfangen ergibt den Wert 0, false. Die empfangende Schleife unterbricht den falschen Wert.

Entfernen Sie close(ch) vom Ende des Programms.

Run it on the playground.

Answer 2

Weil Sie den Kanal nicht schließen, bevor die erste Goroutine beendet wird. Der folgende Code sollte funktionieren.

package main 

import (
    "fmt" 
    "time" 
) 

func main() { 
    ch := make(chan int) 
    go func() { 
     for i := 0; i < 10; i++ { 
      ch <- i 
     } 
     close(ch) 
    }() 
    //go func() { 
     for { 
      if num, ok := <-ch; !ok { 
       break 
      } else { 
       fmt.Printf("%d\n", num) 
      } 
     } 
    //}() 
    time.Sleep(2 * time.Second) 
} 

Probieren Sie es hier aus: https://play.golang.org/p/OdxNqbaZmj