当下一个goroutine被执行时？

Question

我从https://blog.golang.org/pipelines看一下例子：

func main() { 
    in := gen(2, 3) 

    // Distribute the sq work across two goroutines that both read from in. 
    c1 := sq(in) 

    // When does this line below execute and what is in `in`? 
    c2 := sq(in) 

    // Consume the merged output from c1 and c2. 
    for n := range merge(c1, c2) { 
     fmt.Println(n) // 4 then 9, or 9 then 4 
    } 
} 

什么时候c2 := sq(in)运行？正如我所了解的，它不会在上一行结束时执行，而是立即成为goroutine。

将c2接收到下一个传入的消息后，收到的消息后c1？

Answer 1

你的代码不使用够程，为了使用去例程，你应该做这样的事情：

q := make(chan type) 
go sq(in, q) 
go sq(in, q) 

for elem := range q { 
    fmt.Println(elem) 
} 

和SQ必须通过一个通道

func sq(in type, q chan type) { 
    ... 
    q <- valueFromIn 
    ... 
} 

您也可以返回值使用WaitGroup来等候goroutines完成。