【发布时间】:2014-03-11 03:50:58
【问题描述】:
在视频Google I/O 2012 - Go Concurrency Patterns 中,Rob Pike 在视频中大约 17:00 介绍了多路复用模式。使用 fanIn() 函数,谁准备好谁先说话。
但是当我在here - play.golang.org/p/cvAi5MAAKT中组装程序时,它总是按顺序运行
NumCPU: 4 //Edit#1 output
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
这段代码有什么问题?
package main
import "fmt"
import "time"
import "math/rand"
//Pattern #2
//Multiplexing
func fanIn(in1, in2 <-chan string) <-chan string {
c := make(chan string)
go func() {for {c <- <-in1}}()
go func() {for {c <- <-in2}}()
return c
}
func boring(msg string) <-chan string {
c := make(chan string)
go func() {
for i := 0; ; i++ {
c <- fmt.Sprintf("%s %d\n", msg, i)
time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
}
}()
return c
}
func main() {
//Edit#1 according to the first answer, add following two lines
fmt.Println("NumCPU: ", runtime.NumCPU())
runtime.GOMAXPROCS(runtime.NumCPU())
c := fanIn(boring("Joe"), boring("Ann"))
for i := 0; i < 10; i++ {
fmt.Println(<-c)
}
fmt.Println("You're both boring: I'm leaving")
}
更新1: 根据答案,我已经更改了代码,但结果还是一样。我使用的是 Windows 7。请参阅“Edit#1”中的上述更改。
更新2:
我找到了答案:只需将循环数增加到更大的数字(比如 40),即使 GOMAXPROCS 使用默认值,它也会显示不同的顺序。您可以在操场上尝试一下。
【问题讨论】:
标签: design-patterns concurrency go