跳到主要内容

Go Pipeline

高性能Go语言管道处理库

泛型支持

基于 Go 1.18+ 泛型的类型安全实现,支持任意数据类型,提供编译时类型检查。

批处理

支持按大小和时间间隔自动批处理,优化数据处理效率,减少系统调用开销。

并发安全

内置 goroutine 安全机制,支持高并发场景,确保数据处理的线程安全性。