Go iter.Pull 适配拉取式遍历并正确停止

当一个库已经提供 iter.Seq[V]，但业务代码需要“每次取一个值、两路迭代器并排比较，或者命中条件后马上退出”时，可以用 iter.Pull 做适配。它返回 next 和 stop：前者逐个取值，后者负责在没有读完时结束底层迭代。最稳妥的写法是拿到它们后立刻 defer stop()，再用 ok 判断值是否有效。

先确认适配边界：Seq 推送值，next 拉取值

Go 1.23 的标准迭代器把 iter.Seq[V] 定义成接收 yield func(V) bool 的函数。遍历方调用 yield，是“推送式”；而拉取式代码希望自己决定何时读取下一个值，因此两者不能直接互换。iter.Pull 正好放在中间，返回的函数签名是 next func() (V, bool) 和 stop func()。

这张结构图只表达职责关系：yield 属于输入侧，next 属于业务消费侧，stop 是提前结束的控制出口。

处理步骤：拿到 next 后先建立 stop 兜底

下面的适配函数把序列中的第一个满足条件的值取出来。示例没有启动额外 goroutine，也没有把 next 分发给多个消费者；它只演示一个调用方如何掌握拉取和停止责任。

package main

import "iter"

// FirstMatch 拉取序列，返回第一个满足条件的值。
func FirstMatch[V any](seq iter.Seq[V], match func(V) bool) (V, bool) {
	// Pull 返回 next 和 stop；只消费一部分时仍需要 stop 收尾。
	next, stop := iter.Pull(seq)
	defer stop()

	for {
		value, ok := next()
		if !ok {
			var zero V // 序列结束时返回类型零值，并用 false 表示未命中。
			return zero, false
		}
		if match(value) {
			return value, true // 提前返回由 defer stop 负责清理。
		}
	}
}

关键顺序只有三点：先保存 next 与 stop，随后登记 defer stop()，最后才进入循环。这样无论是读完、命中后返回，还是未来在循环里新增错误返回，都不会遗漏停止动作。

提前停止时 stop 才是资源回收开关

如果业务一直读到 ok == false，底层序列已经知道遍历结束；但筛选命中、达到数量上限或校验失败时，调用方会提前离开循环。此时不能只写 break 就认为资源已经释放，尤其是序列内部可能持有协程、缓冲区或其他需要收尾的状态。

对值的处理应先检查 ok，对生命周期的处理则交给 stop。下面的关系图强调的是静态责任，不是执行截图或时间轴。

快速判断：哪些边界需要在代码评审时拦住

延伸问答

读到 false 后还需要调用 stop 吗？

规范上读完后再调用是允许的，重复调用也允许；工程上仍建议统一保留 defer stop()，避免以后加入提前返回时漏掉收尾。

可以把 next 分给多个 goroutine 吗？

不可以把同一组 next 或 stop 并发调用。需要并行处理时，先由单一消费者顺序拉取，再把已经取出的值投递给工作池。

为什么不用直接 for range？

普通 for range 更适合单路消费；当代码要并排比较两条序列、按条件拉取或精确控制一次取值时，iter.Pull 才能提供明确的 next/stop 边界。

落地前可再复核三件事：运行时 Go 版本是否匹配、每次取值是否先判断 ok、所有提前退出是否都经过已登记的 stop。这三项比把拉取循环写得更复杂更重要。