Golang管道过滤器模式 channel流水线-Golang-PHP中文网

Golang管道过滤器模式 channel流水线

P粉602998670

发布： 2025-08-28 11:25:01

原创

180人浏览过

Go语言中管道过滤器模式利用channel实现数据流的分步处理，通过Source生成数据、Filter进行并发处理、Sink收集结果，结合扇出扇入优化性能，提升程序可读性与并发效率。

golang管道过滤器模式 channel流水线

在Go语言中，管道过滤器模式（Pipeline Pattern）是一种常见的并发设计模式，利用

channel

登录后复制

将数据流按阶段处理，像流水线一样传递。这种模式非常适合数据转换、清洗、计算等分步处理场景，能有效提升程序的可读性和并发性能。

基本概念：什么是管道过滤器模式

管道过滤器模式由多个“过滤器”组成，每个过滤器是一个函数或goroutine，负责对数据进行特定处理，然后通过

channel

登录后复制

将结果传递给下一个阶段。整个流程就像工厂中的流水线，数据依次流经各个处理节点。

核心组件包括：

Source（源头）：生成初始数据流
Filter（过滤器）：对数据进行处理，如过滤、映射、转换
Sink（终点）：接收最终结果，如收集、输出或存储

构建简单流水线：分步处理整数流

以下是一个将整数流进行“平方 → 过滤奇数 → 输出”的简单示例：

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

func main() { // 阶段1：生成数据 nums := generator(1, 2, 3, 4, 5, 6)

// 阶段2：平方处理  
squared := square(nums)  

// 阶段3：只保留奇数  
odds := filterOdd(squared)  

// 阶段4：消费结果  
for result := range odds {  
    fmt.Println(result)  
}

登录后复制

}

func generator(nums ...int) <-chan int {
out := make(chan int)
go func() {
for _, n := range nums {
out <- n
}
close(out)
}()
return out
}

func square(in <-chan int) <-chan int {
out := make(chan int)
go func() {
for n := range in {
out <- n * n
}
close(out)
}()
return out
}

func filterOdd(in <-chan int) <-chan int {
out := make(chan int)
go func() {
for n := range in {
if n%2 == 1 {
out <- n
}
}
close(out)
}()
return out
}

输出为：1, 9, 25，即 1², 3², 5²。