14.12 链式协程

下面的演示程序 chaining.go 再次展示了启动巨量的Go协程是多么容易。这些协程已全部在 main 函数中的 for 循环里启动。当循环完成之后，一个0被写入到最右边的通道里，于是100,000个协程开始执行，接着1000000这个结果会在1.5秒之内被打印出来。

这个程序同时也展示了如何通过flag.Int来解析命令行中的参数以指定协程数量，例如：chaining -n=7000会生成7000个协程。

示例 14.17 - chaining.go

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
}

链接

• 目录
• 上一节：限制同时处理的请求数
• 下一节：在多核心上并行计算