Go iter.Pull 如何把迭代器变成手动拉取：Stop 调用与资源释放边界

有些遍历并不适合直接写成 for range：调用方可能要一次取一个值，遇到首个符合条件的记录就停，或者需要把两个迭代器交错消费。Go 的 iter.Pull 正好把 iter.Seq 这种“由迭代器推送值”的形式，转换成可手动调用的 next 和 stop。

只要没有让 next 返回结束信号就提前离开，调用方就应当用 defer stop() 收尾；完整消费到 ok == false 后再调用一次 stop 也安全。

iter.Pull 解决的是消费方式，不是重新生成数据

iter.Seq[V] 的形状是一个接收 yield func(V) bool 的函数。迭代器主动调用 yield，直到数据走完，或者 yield 返回 false。这种 push 方式和 for v := range seq 很搭，但当调用方想把“取下一个值”放进自己的状态机时，就需要 iter.Pull。

package main

import (
    "fmt"
    "iter"
)

func numbers() iter.Seq[int] {
    return func(yield func(int) bool) {
        for i := 1; i 

这段代码的调用链很短：iter.Seq 提供序列，iter.Pull 建立转换，调用方通过 next 取值，并用 stop 结束这次消费。defer stop() 放在取得函数之后，能覆盖正常结束、提前 break 和后续新增的返回分支。

next 的 false 到底表示什么

next 每次返回一个值和一个布尔值。布尔值为 true 时，值有效；序列已经结束时返回元素类型的零值和 false。不要只检查返回值本身，例如整数序列里的 0 可能是合法数据，结束判断必须看 ok。

next, stop := iter.Pull(numbers())
defer stop()

for {
    value, ok := next()
    if !ok {
        fmt.Println("done")
        break
    }
    fmt.Println("value:", value)
}

完整消费时，最后一次 next 返回 false，迭代器已经知道没有更多值。即便如此，stop 仍然可以安全调用；官方文档也明确说明，序列结束后调用 stop 或重复调用它都是允许的。

提前找到目标时，stop 是释放边界

更常见的写法是取到目标值就返回。此时最后一次 next 没有返回 false，底层迭代器仍可能停在中途。官方示例建议把 stop 放进 defer，让迭代器有机会结束自己的工作并返回。

func firstEven(seq iter.Seq[int]) (int, bool) {
    next, stop := iter.Pull(seq)
    defer stop()

    for {
        value, ok := next()
        if !ok {
            return 0, false
        }
        if value%2 == 0 {
            return value, true
        }
    }
}

这里的安全边界是“消费方不再需要更多值”，而不是“函数是否已经返回”。如果以后在循环里增加过滤、日志或异常分支，defer stop() 仍然会执行；把它遗漏在某个分支里，则容易让单次迭代的收尾依赖调用者记忆。

并发调用 next 和 stop 要先划清边界

iter.Pull 适合由一个消费流程按顺序驱动。next 与 stop 不能被多个 goroutine 同时调用；因此不要把同一个 next 闭包直接塞给多个 worker，也不要让一个 goroutine 取值、另一个 goroutine 随意停止。

• 需要并行处理元素时：先由一个 goroutine 顺序调用 next，再把已经取出的值送入工作队列。
• 需要提前终止时：让拥有 next 的消费流程负责调用 stop，外部通过受控信号通知它退出。
• 需要复用数据时：确认原始 iter.Seq 是否是单次迭代器，不要默认停止后可以从头开始。

三个容易混淆的细节

stop 不是 context.CancelFunc

stop 结束的是这次迭代器消费。它不会自动取消数据库请求、网络请求或业务 goroutine；那些资源仍要由自己的 context.Context、关闭函数或错误路径管理。

next 返回 false 后不用读取旧值

结束时的值是元素类型零值，判断逻辑应先看 ok，不要把零值当成一条有效记录继续处理。

不要把 stop 省略当作性能优化

正常跑完整个序列时，收尾通常自然发生；但调用方一旦提前返回，省略 stop 就可能让迭代器无法及时完成清理。defer stop() 的开销换来的是明确的生命周期边界。

相关问题

已经读到 false，还需要调用 stop 吗？

建议保留。官方语义允许在序列结束后调用 stop，统一写成 defer stop() 能减少分支差异。

stop 可以调用多次吗？

可以。重复调用 stop 是合法的，但仍应让代码保持单一收尾路径，避免读者误以为需要手动计数。

能不能让多个 goroutine 共享 next？

不能直接这样做。next 和 stop 的并发调用不受支持；要并行处理，请先单线程取值，再把值交给后续 worker。

小结

iter.Pull 的价值在于把迭代器的消费控制权交给调用方。记住三件事就够了：用 ok 判断 next 是否还有数据，提前离开时用 defer stop() 收尾，同一个 pull 迭代器不要跨 goroutine 并发调用。这样写，手动拉取就不会变成一条隐蔽的生命周期漏洞。