大纲 Channel Fan-in func fanIn(sum1, sum2 <-chan int) <-chan int { sum := make(chan int) go func() { for {sum <- <-sum1} }() go func() { for {sum <- <-sum2} }() return sum } Fan-in Chan Chan Chan Fan-in func main() { sum := fanIn(add(1, 2), add(4, 9)) fmt.Println(<-sum) fmt.Println(<-sum) } Select func fanIn(sum1, sum2 <-chan int) <-chan int { sum := make(chan int) go func() { for

试试写个 append()？ 2020 © Changkun Ou · Go 夜读 · Go 2 Generics? A (P)review Example 5: Fan-in Fan-out 30 1 // generic fan-in -- by changkun 2 func Fanin(type T)(ins ...<-chan T) <-chan T { 3 buf := 0

但是有环拓扑结构的数据流系统在实践中很少用。 从上面两个例子可以看出，使用通道来构建数据流系统是很简单和直观的。 从上例可以看出，通过使用数据聚合模块，我们可以很轻松地实现各个模块的 工作协程数量的扇入（fan-in）和扇出（fan-out）。 事实上，我们也可以使用一个简单的通道来代替数据聚合模块的角色。比如， 下面的代码使用两个通道代替了上例中的两个数据聚合器。 1| package main 2|

但是有环拓扑结构的数据流系统在实践中很少用。 从上面两个例子可以看出，使用通道来构建数据流系统是很简单和直观的。 从上例可以看出，通过使用数据聚合模块，我们可以很轻松地实现各个模块的 工作协程数量的扇入（fan-in）和扇出（fan-out）。 事实上，我们也可以使用一个简单的通道来代替数据聚合模块的角色。比如， 下面的代码使用两个通道代替了上例中的两个数据聚合器。 package main ... //

但是有环拓扑结构的数据流系统在实践中很少用。 从上面两个例子可以看出，使用通道来构建数据流系统是很简单和直观的。 从上例可以看出，通过使用数据聚合模块，我们可以很轻松地实现各个模块的工作 协程数量的扇入（fan-in）和扇出（fan-out）。 事实上，我们也可以使用一个简单的通道来代替数据聚合模块的角色。比如，下面 的代码使用两个通道代替了上例中的两个数据聚合器。 1| package main 2|