开俩个协程，一个协程生产数据，另一个协程对数据进行处理，处理完后再把数据发回去，使用管道如何实现？

题目来源：京东

答案：

该问题适合使用pipeline模式(pipeline是一系列将数据输入，执行操作并将数据传回的系统，我们称这些操作都是pipeline的一个stage)，代码如下：

package main
import (
    "fmt"
    "math/rand"
)
func main() {
    // 随机数生成器
    producer := func(num int, done <-chan struct{}) <-chan int {
        produceStream := make(chan int)
        go func() {
            defer close(produceStream)
            for i := 0; i < num; i++ {
                select {
                case <-done:
                    return
                case produceStream <- rand.Intn(99):
                }
            }
        }()
        return produceStream
    }
    // 随机数倍增器
    consumer := func(done <-chan struct{}, produceStream <-chan int) <-chan int {
        consumerStream := make(chan int)
        go func() {
            defer close(consumerStream)
            for v := range produceStream {
                select {
                case <-done:
                    return
                case consumerStream <- v * 2:
                }
            }
        }()
        return consumerStream
    }
    done := make(chan struct{})
    defer close(done)
    produceStream := producer(10, done)
    consumerStream := consumer(done, produceStream)
    for output := range consumerStream {
        fmt.Println("Output: ", output)
    }
}