Go Academy · 课时

处理流程阶段

Q: 「处理流程阶段」这节课中我会学到什么？

串联通道阶段 你通过在浏览器中直接运行的动手代码来练习 Go Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

串联通道阶段

第 3 / 4 课13 个步骤

处理流程阶段 是 CoddyKit 上的免费 Go Academy 课时。这是第 3 节课，共 4 节。你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。这是 Go Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Go Academy 课程共包含 4 节课。

什么是管道

管道是一系列通过通道连接的 stage。每个 stage 接收值、执行工作，然后将结果发送到下游。数据的流动方式就像装配线。

每个 stage 都是一个 Go 协程
stage 之间只通过通道通信
可组合且易于理解

stage 签名约定

按照约定，每个 stage 接收一个或多个仅接收输入通道，并返回一个仅接收输出通道。这样就可以串联 stage。

func stage(in <-chan int) <-chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for v := range in {
            out <- v
        }
    }()
    return out
}

源 stage

第一个 stage 负责生成数据。它通常接收一个切片或可变参数，并将这些数据流式写入通道。

func numbers(vals ...int) <-chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for _, v := range vals {
            out <- v
        }
    }()
    return out
}

转换 stage

此 stage 会将每个值乘以十。它从 in 读取数据，并将转换后的值写入 out。

func tenfold(in <-chan int) <-chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for v := range in {
            out <- v * 10
        }
    }()
    return out
}

过滤 stage

过滤器只会转发满足某个条件的值。在这里，我们保留偶数并丢弃其余值。

func evens(in <-chan int) <-chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for v := range in {
            if v%2 == 0 {
                out <- v
            }
        }
    }()
    return out
}

串联 stage

通过将一个输出传递给下一个输入来组合 stage。这条链读起来几乎像一句话。

pipe := tenfold(evens(numbers(1, 2, 3, 4)))
for v := range pipe {
    fmt.Println(v)
}

defer close(out)

使用 defer close(out) 可以保证 stage Go 协程返回时关闭输出通道，即使您之后添加提前返回也不例外。这样会将流结束信号传递给下游。

完整的管道

先执行源 stage，再执行过滤 stage，最后执行转换 stage。运行它即可看到偶数输入的 tenfold 结果。

package main

import "fmt"

func numbers(vals ...int) <-chan int {
    out := make(chan int)
    go func() { defer close(out); for _, v := range vals { out <- v } }()
    return out
}

func evens(in <-chan int) <-chan int {
    out := make(chan int)
    go func() { defer close(out); for v := range in { if v%2 == 0 { out <- v } } }()
    return out
}

func tenfold(in <-chan int) <-chan int {
    out := make(chan int)
    go func() { defer close(out); for v := range in { out <- v * 10 } }()
    return out
}

func main() {
    for v := range tenfold(evens(numbers(1, 2, 3, 4, 5, 6))) {
        fmt.Println(v)
    }
}

流式处理，而非批处理

值会在生成后逐个流经管道。源 stage 尚未发出最后一个值时，转换 stage 就可以开始处理第一个值。这样可以降低内存占用和延迟。

管道是惰性的

在有人读取其输出之前，stage 不会执行任何工作。如果使用者停止遍历，上游 stage 就会阻塞在发送操作上。这种自然的背压可以避免浪费计算。

添加并发

要加速缓慢的 stage，可以将其扇出为多个读取同一输入的实例，然后合并它们的输出。stage 签名保持不变，只有连接方式发生变化。

快速检查

请测试您对管道的理解。

在交互式课程中回答

回顾

您已学会管道 stage：

每个 stage：接收仅接收输入，并返回仅接收输出
defer close(out) 会传递流结束信号
通过嵌套调用串联 stage
管道以惰性方式流式处理，并提供背压

免费开始

用 AI 导师学习 Go — 免费

在浏览器中编写并运行真实代码，获得全天候 AI 导师的即时帮助，并在网页或应用中继续学习。

课程: 51
课程: 203

免费开始学习查看完整课程

常见问题解答

「处理流程阶段」课时是免费的吗？

是的 — 「处理流程阶段」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Go Academy 课程的其余内容，请升级到 CoddyKit PRO。 Go Academy 课程共包含 4 节课。

「处理流程阶段」这节课中我会学到什么？

串联通道阶段你通过在浏览器中直接运行的动手代码来练习 Go Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Go Academy 需要有经验吗？

无需任何先前经验。CoddyKit 上的 Go Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。这是第 3 节课，共 4 节。

「处理流程阶段」课时需要多长时间？

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。

我能在这节 Go Academy 课中编写并运行代码吗？

能。每节 Go Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

← 返回 Go Academy