次のゴルーチンが実行されたら？

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)実行していますか？私が理解しているように、それは前の行が終了したときではなく、即座にそれがゴルーチンであるときに実行されます。

は

はc2c1によって受信されたメッセージの後に来た後で、次の着信メッセージを受け取ることができますか？

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を使用してください。