ゴルーチン間のデッドロック

Question

行き先2番目のgoroutineをコメントアウトすると、致命的なエラーが発生します。私はこのエラーの原因を理解していません。それを私に説明できますか？送信ゴルーチンからすべての値を受信した後chから受信にループブロックの

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

受信：

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) 
} 

これは、次のコードを印刷します。ランタイムは、プログラムが停止してパニックすることを検出します。

修正はすべての値を送信した後にチャンネルを閉じることである。

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

は、閉じたチャネルで受信は値0, falseを生み出します。受信forループは、false値でブレークします。

プログラムの最後からclose(ch)を削除します。

Run it on the playground。

Answer 2

最初のゴルーチンが終了する前にチャンネルを終了していないためです。以下のコードは動作するはずです。

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) 
} 

ここでそれを試してみてください：https://play.golang.org/p/OdxNqbaZmj