Go iter.Pull 怎样把推送式迭代转换成逐项读取完成一个可复用的最小示例

我第一次把 Go 的函数迭代器接进一个“找到第一个符合条件的值就返回”的读取器时，真正需要改的不是上游数据源，而是消费方式。iter.Pull 可以把 iter.Seq[V] 这种推送式迭代器转换成 next 和 stop：调用一次 next 取一个值，ok=false 表示序列结束；如果提前退出，就用 stop 通知上游收尾。

可复用的最小写法：先用 next, stop := iter.Pull(seq) 建立拉取端，再立刻写 defer stop()，循环里先判断 ok，最后处理当前值。

先把推送式迭代器写成可停止的序列

Go 1.23 引入了标准 iter 包和函数迭代器。一个 iter.Seq[int] 本质上是接收 yield func(int) bool 的函数：上游把值交给 yield，而返回值表示下游是否还需要继续。

package main

import "iter"

// numbers 生成 1 到 limit；下游返回 false 时立即停止继续生成。
func numbers(limit int) iter.Seq[int] {
	return func(yield func(int) bool) {
		for i := 1; i 

同一个序列既可以直接交给 for range，也可以交给 iter.Pull。选择 Pull 的理由通常是调用方要自己决定“什么时候取下一项”，而不是让循环体一次接收所有值。

用 next 逐项读取，并把 stop 放在 defer 里

下面的函数只取第一个偶数，命中后立即返回。注意它并没有要求 numbers 改成另一种接口，适配动作只发生在消费端。

package main

import (
	"fmt"
	"iter"
)

// firstEven 找到第一个偶数；没有找到时返回 false。
func firstEven(seq iter.Seq[int]) (int, bool) {
	next, stop := iter.Pull(seq)
	// 可能在序列结束前返回，所以要让上游有机会停止清理。
	defer stop()

	for {
		value, ok := next()
		if !ok {
			// ok=false 代表没有更多有效值，value 此时只是零值。
			return 0, false
		}
		if value%2 == 0 {
			return value, true
		}
	}
}

func main() {
	value, ok := firstEven(numbers(5))
	fmt.Println(value, ok) // 输出：2 true
}

这里最容易漏掉的是 stop。上游若在 yield 内部启动了 goroutine、持有通道或等待其他资源，调用方提前返回却不停止，生产端就可能继续等待。把 defer stop() 放在 Pull 后一行，可以同时覆盖命中条件、错误返回和后续重构出的多个出口。

ok、结束和提前停止分别代表什么

next 返回的第二个值不是“本次有没有读到非零值”，而是当前值是否有效。序列中本来就可以合法出现 0，所以要写成 value, ok := next() 后先判断 ok。正常读到末尾时返回零值和 false；调用 stop 后再调用 next 也会继续得到零值和 false，但业务代码通常不需要再读。

如果循环完整消费到 ok=false，严格说不调用 stop 也能结束；不过统一保留 defer stop() 更容易抵抗未来新增的 break、过滤条件和错误分支。next 与 stop 应由同一个消费流程管理，不要把同一个 Pull 会话随意交给多个并发 goroutine。

什么时候值得用 Pull

需要把迭代器接入传统的逐项 API、比较两条序列、找到首个匹配值或在每次读取之间插入调用方逻辑时，Pull 很合适。若只是把所有元素顺序处理一遍，直接使用 for value := range seq 通常更短，也天然处理了循环提前结束时的 yield 停止。Pull 的价值是控制读取节奏，不是替代所有 for range。

常见问题：

能不能只调用 next，不调用 stop？只有确定已经读到 ok=false 时才可以省略；可复用函数建议始终 defer stop。

为什么不能用 value 是否为零判断结束？因为零值可能是序列中的真实元素，结束边界必须看 ok。