管道模式是一种以并发方式分阶段处理数据的强大方法。每个阶段对数据执行不同的操作，然后传递到下一个阶段。
使用通道来传递数据，管道模式在很多情况下可以提高性能。
这个想法真的非常简单，每个阶段都会迭代一个通道，拉取数据直到没有剩余的数据。对于每个数据项，该阶段都会执行其操作，然后将结果传递到输出通道，最后当输入通道中没有更多数据时关闭通道。 关闭通道很重要，这样下游阶段才能知道何时终止
创建一个数字序列，将它们加倍，然后过滤低值，最后将它们打印到控制台。
func produce(num int) chan int {
out := make(chan int)
go func() {
for i := 0; i 10 {
out
<p>显然有一种更易读的方式来构造 main():<br></p>
<pre class="brush:php;toolbar:false">func main() {
input := produce(10)
doubled := double(input)
filtered := filterBelow10(doubled)
print(filtered)
}
根据自己的喜好选择您的风格。
您会在这里添加什么？请在下面留下您的评论。
谢谢！
这篇文章以及本系列所有文章的代码可以在这里找到
