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

题目来源：京东

答案：古尔班通

该问题适合使用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)
    }

}