关于chan的疑问

来源:3-2 基础节点

sliverg

2018-06-07 06:50

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!

报错呢?

写回答 关注

2回答

  • openset
    2018-06-10 19:02:35

    改成这样就可以了:

    https://img1.mukewang.com/5b1d052a0001ac5d11921054.jpg

  • openset
    2018-06-10 18:54:54

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


搭建并行处理管道,感受GO语言魅力

通过搭建并行数据处理管道,展示go语言在并发编程方面的优势

19375 学习 · 78 问题

查看课程

相似问题