Go iter.Pull2 如何把双序列迭代器接入旧式循环：next、stop 与提前退出

批处理任务常常已经有一段旧式 for 循环：每次取一对键和值，遇到首个无效记录就停止。Go 1.23 的 iter 包可以用 iter.Pull2 把双值序列接成这种逐次拉取的接口，关键不在“换一种写法”，而在于把 next 的结束信号和 stop 的清理责任放在正确位置。

把 iter.Seq2 接入旧循环时，用 next 逐对读取，用 ok 判断结束；只要还没读到结束就提前离开循环，就必须让 defer stop() 接管收尾。

先把 Seq2 的边界说清楚：一轮返回一对值

iter.Seq2[K, V] 是一个接受 yield func(K, V) bool 的迭代器。它更接近“生产者把数据推给回调”：回调返回 true 才继续，返回 false 就提前结束。比如下面的序列按顺序产生三条配置记录：

func settings() iter.Seq2[string, int] {
    return func(yield func(string, int) bool) {
        for _, item := range []struct {
            key   string
            limit int
        }{{"cache", 30}, {"retry", 3}, {"batch", 100}} {
            if !yield(item.key, item.limit) {
                return
            }
        }
    }
}

这种写法适合 range，但旧代码往往还要在每次读取后立刻做一次校验、打点或分支处理。此时把它转换成拉取接口，循环的控制权会回到消费方。

用 iter.Pull2 接上旧式循环：next 返回 ok

下面的消费函数只接受 limit 不超过 50 的记录。iter.Pull2 把 Seq2 变成 next 与 stop；每次调用 next 会同时拿到键、值和 ok。注意，配置值为 0 也可能是合法数据，所以结束判断只能看 ok。

func firstSmallLimit(seq iter.Seq2[string, int]) (string, int, bool) {
    next, stop := iter.Pull2(seq)
    defer stop()

    for {
        key, limit, ok := next()
        if !ok {
            return "", 0, false
        }
        if limit 

这里的 next 调用链很短：消费函数调用 next，Pull2 再让原来的 Seq2 调用 yield；下一次循环继续从上次停下的位置取值。读到 ok=false 后，键和值都会是各自类型的零值，但代码不依赖它们作判断。

提前退出为什么还要 stop：把未完成的序列收回来

如果循环读到目标项就直接返回，底层序列还没有收到结束信号。defer stop() 是这里最稳妥的收口方式：无论是找到记录、序列读完，还是后续代码增加了错误返回，stop 都会被调用。

stop 不是“再取一次数据”。它负责结束仍在等待下一次 yield 的拉取过程。官方文档同时说明：读到结束后再调用 stop 是允许的，重复调用也安全；但 next 和 stop 不应由多个 goroutine 同时调用。

func collectUntil(seq iter.Seq2[string, int], max int) map[string]int {
    next, stop := iter.Pull2(seq)
    defer stop()

    result := make(map[string]int)
    for {
        key, value, ok := next()
        if !ok {
            break
        }
        if value > max {
            break
        }
        result[key] = value
    }
    return result
}

这个版本有两个结束点：一是 ok=false 的自然结束，二是 value > max 的业务提前结束。两条路径都经过同一个 stop，调用方不用复制清理代码。

用一个小基准检查取值边界，而不是猜性能

如果只是把 Seq2 改成 range，通常没有必要引入拉取层。可以先用一个固定序列做基准，分别测量完整消费和命中后提前退出的场景。指标只看每轮处理的记录数、分配次数和耗时，避免把机器差异误当成 API 结论。

func BenchmarkPull2(b *testing.B) {
    seq := settings()
    b.ReportAllocs()
    for i := 0; i 

基准之外还应覆盖空序列、第一项就命中、最后一项才命中和完全没有命中的输入。真正需要关注的是调用方是否正确处理 ok，以及提前返回时 stop 是否始终可达。

常见问题：Pull2 适合哪些循环

可以在多个 goroutine 中共享同一个 next 吗？

不可以。next 与 stop 的并发调用不受支持；如果需要并发处理，应在单个消费循环里先分发已经取出的数据。

读到 ok=false 后还要手动清零键和值吗？

不需要。结束时 Pull2 已返回两个类型零值和 ok=false，业务只应使用布尔值判断是否还有数据。

只用 range 时还需要 Pull2 吗？

通常不需要。只有当旧式循环需要逐次拉取、在中途返回，或要把读取动作放进已有的分支控制时，Pull2 才更贴合代码结构。

收束：让结束责任跟着消费函数走

iter.Pull2 的价值是把双值推送序列转换成明确的逐次读取边界。写法上记住三件事：用 ok 判断结束，用 defer stop() 覆盖提前返回，保持 next 与 stop 在同一个消费 goroutine 中。这样改造旧循环时，数据语义和清理路径都能被测试直接验收。