在 golang 函数链中使用管道可以高效地移动数据，因为管道是并发原语，允许协程之间安全传递数据。管道由一个发送端和一个接收端组成，数据通过通道传递，通道使用 chan 关键字指定数据类型。要发送数据，使用 运算符。在函数链中使用管道，只需在函数之间传递通道，并将通道作为函数参数。管道也可以用于处理大数据集或并行计算，例如，代码片段使用管道并行计算素数。

在 Golang 函数链中使用管道

管道是一个并发原语，允许在不同的协程之间安全地传递数据。它们在函数链中特别有用，因为它们可以使数据流在不同的函数之间高效地移动。

管道 basics

立即学习“go语言免费学习笔记（深入）”；

管道由两个部分组成：一个发送端和一个接收端。数据通过 chan 关键字创建的通道传递，它指定通道的数据类型。

ch := make(chan int)

要发送数据，请使用 <- 运算符：

ch <- 10 // 发送一个整数到通道

要从通道接收数据，请使用 -> 运算符：

result := <-ch // 从通道接收一个整数

在函数链中使用管道

在函数链中使用管道非常简单。只需在函数之间传递通道，并将通道作为函数参数。例如：

func increment(n int) int {
  return n + 1
}

func double(n int) int {
  return n * 2
}

func main() {
  ch := make(chan int)

  // 向通道发送数据
  go func() { ch <- 2 }( )

  // 在函数链中使用管道
  result := double(increment( <-ch ))

  fmt.Println(result) // 输出：6
}

在这里，ch 通道在 increment 和 double 函数之间传递。go func() 是一个匿名函数，它将数据发送到通道，然后立即返回。

实战案例

管道还可以用于处理大数据集或执行并行计算。例如，以下代码片段使用管道并行计算素数：

func isPrime(n int) bool {
    for i := 2; i <= int(math.Sqrt(float64(n))); i++ {
        if n%i == 0 {
            return false
        }
    }
    return true
}

func main() {
    numbers := make(chan int, 10) // 通道大小为 10
    results := make(chan bool, 10) // 通道大小为 10

    // 生产者：向通道发送数字
    go func() {
        for i := 2; i < 100000; i++ {
            numbers <- i
        }
        close(numbers) // 关闭通道，表示没有更多数据发送了
    }()

    // 消费者：从通道接收数字，并检查它们是否为素数
    for i := 0; i < 10; i++ {
        go func() {
            for n := range numbers { // 遍历发送到通道的数据
                isPrime := isPrime(n)
                results <- isPrime
            }
        }()
    }

    // 从结果通道接收并打印
    fmt.Println("素数：")
    for i := 0; i < 100000; i++ {
        if <-results {
            fmt.Print(i, " ")
        }
    }
}

在这个例子中，生产者协程向 numbers 通道发送数字，然后关闭通道。消费者协程从 numbers 通道接收数字，使用 isPrime 函数检查它们是否为素数，然后将结果发送到 results 通道。