Go 中的管道模式

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《Go 中的管道模式》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

管道模式是一种以并发方式分阶段处理数据的强大方法。每个阶段对数据执行不同的操作，然后传递到下一个阶段。

使用通道来传递数据，管道模式在很多情况下可以提高性能。

这个想法真的非常简单，每个阶段都会迭代一个通道，拉取数据直到没有剩余的数据。对于每个数据项，该阶段都会执行其操作，然后将结果传递到输出通道，最后当输入通道中没有更多数据时关闭通道。 关闭通道很重要，这样下游阶段才能知道何时终止

创建一个数字序列，将它们加倍，然后过滤低值，最后将它们打印到控制台。

func produce(num int) chan int {
    out := make(chan int)
    go func() {
        for i := 0; i < num; i++ {
            out <- rand.intn(100)
        }
        close(out)
    }()
    return out
}

func double(input <-chan int) chan int {
    out := make(chan int)
    go func() {
        for value := range input {
            out <- value * 2
        }
        close(out)
    }()
    return out
}

func filterbelow10(input <-chan int) chan int {
    out := make(chan int)
    go func() {
        for value := range input {
            if value > 10 {
                out <- value
            }
        }
        close(out)
    }()
    return out
}

func print(input <-chan int) {
    for value := range input {
        fmt.printf("value is %d\n", value)
    }
}

func main() {

    print(filterbelow10(double(produce(10))))

}

显然有一种更易读的方式来构造 main():

func main() {

    input := produce(10)
        doubled := double(input)
    filtered := filterBelow10(doubled)
    print(filtered)

}

根据自己的喜好选择您的风格。

您会在这里添加什么？请在下面留下您的评论。

谢谢！

这篇文章以及本系列所有文章的代码可以在这里找到

本篇关于《Go 中的管道模式》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！