Go iter.Pull2 如何安全提前停止：双序列拉取与退出回收边界

把键值迭代器交给普通 for range 很顺手，但遇到“读到某个键就停”或“每次要同时拿到 key 和 value”时，iter.Pull2 更贴近调用方的节奏。它把 iter.Seq2 转成 next 与 stop 两个函数；真正容易漏掉的是提前结束后的清理：没有消费完整个序列时，必须调用 stop。

iter.Pull2 适合需要逐项拉取键值对的场景；只要循环可能提前退出，就用 defer stop() 把迭代器收尾交还给它。

Pull2 改变的只是消费节奏

iter.Seq2[K, V] 是把成对值交给回调的 push 形式，常见的消费方式是 for key, value := range seq。iter.Pull2 没有改变序列本身，也没有把数据自动收集成切片，而是给调用者一个可以逐次询问的入口。

这里的“拉取”更像一个小型游标。调用方决定什么时候问下一项，也决定在哪个条件下停下来。

next 如何把双值序列变成可检查的游标

下面的示例构造一个最小的 iter.Seq2，然后用 iter.Pull2 只查找第一个满足条件的键。代码中的 next 负责推进，ok 负责区分“读到零值”与“真的结束”。

package main

import (
    "fmt"
    "iter"
)

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

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

func main() {
    seq := func(yield func(string, int) bool) {
        for _, item := range []struct {
            key   string
            value int
        }{{"low", 2}, {"hit", 9}, {"later", 12}} {
            if !yield(item.key, item.value) {
                return
            }
        }
    }
    key, found := firstLarge(seq, 8)
    fmt.Println(key, found)
}

运行这段代码会得到 hit true。返回 key 的那一轮已经满足条件，函数随后离开循环；defer stop() 仍会执行，让底层 yield 链路收到停止信号。

为什么提前 return 仍然需要 stop

把 stop 想成“通知迭代器结束”，比把它理解成普通的关闭按钮更准确。Pull2 启动底层序列后，序列可能还停在自己的循环里。调用方提前 return 只改变了调用方的控制流，不会凭空让底层函数完成。

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

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

最小规则只有两条：从 Pull2 拿到 stop 后尽早安排 defer stop()；每次读取都先检查 ok，再使用 key 和 value。这样既覆盖命中返回，也覆盖序列自然结束。

旧代码迁移时要看清三个边界

完整消费时也能保留 stop

即使当前实现通常会走到 ok=false，保留 defer stop() 仍然更稳。以后把完整扫描改成阈值查找时，不需要再回头补清理。

零值不是结束信号

键或值可能本来就是空字符串或 0。判断结束只能看 ok，不能拿某个返回值的零值作哨兵。

Pull2 不是并发取消

stop 只负责结束这次拉取对应的迭代过程。它不替代 context.Context，也不会自动停止已经独立启动的网络请求或后台任务；那些资源仍要由业务层显式管理。

最小验证：分别覆盖命中、扫完和提前退出

可以用三组输入检查迁移是否正确：阈值低于第二项时应返回 hit true；阈值高于全部项时应返回空键和 false；在序列函数里记录收到的 yield=false，可验证提前 return 后 stop 确实让底层循环退出。

func makeSeq() iter.Seq2[string, int] {
    return func(yield func(string, int) bool) {
        for _, item := range []struct{ key string; value int }{
            {"low", 2}, {"hit", 9}, {"later", 12},
        } {
            if !yield(item.key, item.value) {
                return
            }
        }
    }
}

如果你只是把所有键值对顺序处理一遍，直接使用 for key, value := range seq 更简单；只有消费方需要逐项控制、提前退出或与另一段拉取逻辑对齐时，Pull2 才值得引入。

相关问题

Pull2 返回的 ok=false 后还能继续调用 next 吗？

不应把它当作还有数据的入口。ok=false 表示当前序列已结束，应结束消费；提前退出的路径则依赖 stop。

为什么不直接把 Seq2 收集到 map？

收集会改变消费方式并保留全部结果。只找一个匹配项时，next 可以在命中后停止，代码边界更贴近任务。

什么时候用普通 range？

没有提前退出、也不需要把“下一项”交给其他判断逻辑时，普通 range 更直观，少一层 next 和 stop 管理。

记住一个可执行的判断：需要逐项拉取就看 next，可能提前结束就安排 stop，是否结束只看 ok。这三点足以覆盖 iter.Pull2 最容易出错的使用边界。