# 14.12 链式协程
下面的演示程序 chaining.go 再次展示了启动巨量的Go协程是多么容易。这些协程已全部在 main 函数中的 for
循环里启动。当循环完成之后,一个0被写入到最右边的通道里,于是100,000个协程开始执行,接着1000000
这个结果会在1.5秒之内被打印出来。
这个程序同时也展示了如何通过flag.Int
来解析命令行中的参数以指定协程数量,例如:chaining -n=7000
会生成7000个协程。
package main
import (
"flag"
"fmt"
)
var ngoroutine = flag.Int("n", 100000, "how many goroutines")
func f(left, right chan int) { left <- 1 + <-right }
func main() {
flag.Parse()
leftmost := make(chan int)
var left, right chan int = nil, leftmost
for i := 0; i < *ngoroutine; i++ {
left, right = right, make(chan int)
go f(left, right)
}
right <- 0 // bang!
x := <-leftmost // wait for completion
fmt.Println(x) // 100000, ongeveer 1,5 s
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
译者注:原本认为leftmost的结果为1,认为只在最初做了一次赋值,实际结果为100000(无缓存信道具有同步阻塞的特性)
1.主线程的right <- 0,right不是最初循环的那个right,而是最终循环的right
2.for循环中最初的go f(left, right)因为没有发送者一直处于等待状态
3.当主线程的right <- 0执行时,类似于递归函数在最内层产生返回值一般