golang pipline 架构

Go语言的Pipeline架构通常用于处理大量数据的情况，可以将数据分成多个阶段，每个阶段都是一个goroutine。每个goroutine从输入通道中接收数据，经过处理后将结果发送到输出通道中，再由下一个goroutine处理。这种方式可以提高程序的并发性和处理效率。

Pipeline架构的实现可以分为以下几个步骤：
1. 将任务分成多个阶段，每个阶段使用一个goroutine进行处理。
2. 使用通道传递数据，每个阶段都有一个输入通道和一个输出通道。
3. 使用sync.WaitGroup等工具控制所有goroutine的执行和退出。
4. 在最后一个阶段关闭输出通道，以便前面的goroutine能够正确退出。

下面是一个简单的Pipeline架构示例：

package main

import "fmt"

func main() {
    // 创建输入管道
    input := make(chan int)

    // 第一阶段：将输入数据平方
    square := func() {
        for n := range input {
            fmt.Println("square:", n*n)
            // 将结果发送到下一个阶段
            output <- n*n
        }
        close(output)
    }

    // 第二阶段：将平方结果加1
    addOne := func() {
        for n := range output {
            fmt.Println("addOne:", n+1)
        }
    }

    // 创建输出管道
    output := make(chan int)

    // 启动第一阶段
    go square()

    // 启动第二阶段
    go addOne()

    // 发送数据到第一阶段
    for i := 0; i < 5; i++ {
        input <- i
    }

    // 关闭输入管道，等待所有goroutine退出
    close(input)
}

这个示例中，我们将数据分成了两个阶段，第一个阶段将输入数据平方，并将结果发送到第二个阶段，第二个阶段将平方结果加1并输出。在程序运行时，我们向输入管道发送了5个整数，它们经过第一阶段的处理后，结果被发送到第二阶段，最终输出了每个数字的平方加1的结果。