2

「Go Concurrency」と呼ばれる Rob Pike の Google I/O 2012 の講演をフォローしようとしています。「アン」と「ジョー」がロックステップで話さないように、チャネルが多重化されている例を試しています。しかし、以下のコードを使用すると、ロックステッピングのままです。どこが間違っていますか？

ビデオ: http://www.youtube.com/watch?v=f6kdp27TYZs&feature=player_detailpage#t=1025s

package main

import (
    "fmt"
    "time"
    "math/rand"
    )

func fanIn(input1, input2 <-chan string) <-chan string {
    c := make(chan string)
    go func() { for {c <- <-input1 } }()
    go func() { for {c <- <-input2 } }()
    return c
}

func main() {
    c := fanIn(boring("Joe"), boring("Ann"))
    for i:=0; i<10; i++ {
        fmt.Println(<-c)
    }
    fmt.Printf("You're both boring, I'm leaving...\n")
}

func boring(msg string) <-chan string {
    c := make(chan string)
    go func() { // launch goroutine from inside the fn
        for i:=0; ; i++ {
            c <- fmt.Sprintf("%s %d", msg, i)
            time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond )
        }
    }()
    return c
}

そして、これの出力（Ubuntu 10.04 LTSでバージョンgo1.0.2に移動）

Joe 0
Ann 0
Joe 1
Ann 1
Joe 2
Ann 2
Joe 3
Ann 3
Joe 4
Ann 4
You're both boring, I'm leaving...

どこで私は間違えましたか？ありがとう！

4

1 に答える 1

7

あなたのコードは問題ありません。それらを同期から外すには、それよりも少し時間がかかる傾向があります。さらにループするだけで、ロックステップから抜け出すことができます。

for i := 0; i < 20; i++ { // Going up to 20 is enough to usually see it
    fmt.Println(<-c)
}

私はこの出力を得ました：

ジョー 0
アン 0
ジョー1
アン 1
ジョー2
アン 2
ジョー3
アン 3
ジョー4
アン 4
ジョー5
アン 5
ジョー6
アン 6
アン7
ジョー7
ジョー 8
ジョー9
アン 8
アン 9
于 2013-05-19T19:52:46.690 に答える