在 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 通道。
