go 流水线模式
package main
import (
"fmt"//输出包
)
func main() {
out:=make(chan int)//创建无缓冲通道一个out
go func(){
for i:=0;i<10;i++{
out<-i//把i发送到out通道中去
}
close(out)//全部发送完毕关闭通道out
}()
in:=out//把out通道赋值给in。用于在下一个阶段中处理数据。
out1:=make(chan int)//创建一个新的int类型的无缓冲的通道.用于存储处理后的数据
go func(){
for v:=range in{
out1<-v+6//把in通道内的数据每一个+1赋值给out通道中,
}
close(out1)//全部+1后，关闭out通道.
}()
for v:=range out1{
fmt.Println(v)
}
}
解释： ，可以看到有两个goroutine构成了一个简单的流水线。第一个goroutine负责生成0到9这些数字并发送到out通道中，第二个goroutine接收out通道中的数据，对每个数据加6后发送到out1通道中。最后，在主goroutine中从out1通道读取处理后的数据并打印输出
本文参与?腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2024-03-23，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
对象存储
对象存储（Cloud Object Storage，COS）是由腾讯云推出的无目录层次结构、无数据格式限制，可容纳海量数据且支持 HTTP/HTTPS 协议访问的分布式存储服务。腾讯云 COS 的存储桶空间无容量上限，无需分区管理，适用于 CDN 数据分发、数据万象处理或大数据计算与分析的数据湖等多种场景。