1. 过程为Pipeline -> Fan_out -> Fan_in。 其中一个 goroutine 读取数据，将其写入不同的 channel，多个 worker 分别进行消费，消费完毕之后再写入同一个 channel，再由一个 goroutine 输出。 2. 用 ants 进行管理 goroutine（/dog）。 另外文章还有个重点：Fan-out（扇出）和 Fan-in（扇入）这两个模型一定要从 0 写出来，不要以为看了就会了