                        课程
                    
                        /后端开发
                        
                            /Go
                        
                        /搭建并行处理管道，感受GO语言魅力

关于chan的疑问

package main

import (
   "fmt"
)

func main() {
   ch := make(chan string)
   for i := 0; i <= 5; i++ {
      go printHelloWorld(i, ch)
   }
   for {
      if msg,ok := <-ch;ok{
         fmt.Println(msg)
      }else{
         break
      }
   }

}

func printHelloWorld(i int, ch chan string) {
      ch <- fmt.Sprintf("hello world %d\n", i)
}

老师：为什么我这段代码输出会有个

fatal error: all goroutines are asleep - deadlock!

报错呢？

sliverg

2018-06-07

源自：搭建并行处理管道，感受GO语言魅力 3-2

关注问题我要回答

1111

操作

收起

2 回答

openset
2018-06-10

改成这样就可以了：

0 回复有任何疑惑可以回复我~

收起回答

openset
2018-06-10

ch没有关闭，一直在等待。

package mainimport (	"fmt")func main() {	ch := make(chan string)	for i := 0; i <= 5; i++ {		go printHelloWorld(i, ch)	}	for i := 0; i <= 5; i++ {		fmt.Println(<-ch)	}}func printHelloWorld(i int, ch chan<- string) {	ch <- fmt.Sprintf("hello world %d\n", i)}