假如: 这每一个数组都是一个对象, 一个很大的对象, 处理链路比较长. 这时候, 放入管道中. 就可以并发处理了. 不影响后面的流程....该怎么处理, 就怎么处理.
package pipeline
func ArraySource(arr ...int) chan int {
out := make(chan int)...传进来一个数组, 然后, 我们将数组放入管道中进行处理....这个就是搭建的管道通信方式
还有一个部分就是带有缓冲的管道. 发现,如果管道没有缓冲, 那就, 就要一直等待....然后传输给其他机器进行数据处理. 数据处理以后, 在发送给其他机器, 进行数据合并, 最后入库. 这几个步骤可能都发生在不同的机器上.