Go iter.Pull 怎样把推送式迭代转换成逐项读取在批处理代码中减少额外分配

用 next, stop := iter.Pull(seq) 可把推送式迭代器适配为逐项读取接口。在拥有这次消费的函数中立即安排 defer stop()，每次读取同时判断 ok，并直接处理当前值，就能避免为了手动读取而先收集一整批结果。Pull 自身也有适配成本，不能据此承诺零分配或总分配一定下降。

官方地址：https://pkg.go.dev/iter

什么时候需要逐项读取而不是直接 range

读者问：上游已经返回 iter.Seq，但批处理器想自己决定何时取下一项，是否必须先转成切片？

不必。普通的从头处理到尾通常直接 range 更简单；消费端需要把“读下一项”作为一个动作时，Pull 才有明确用途。它保留原来的数据源，把访问形式改成 next 与 stop。本文用一个有限整数序列演示，处理结果是累加值，不保留输入副本。

这个选择解决的是消费接口问题。如果上游一开始就把所有结果装进内存，Pull 不会撤销那部分存储。要避免整批中间结果，需要源迭代器本身也能按需交付，而下游处理函数不再把所有值追加进新切片。

next 和 stop 在批处理函数里怎样使用

下面示例适用于 Go 1.23 及以上。Consume 每次最多请求 limit 项，实际序列更短时正常结束。负数上限和 nil 函数值作为调用参数错误返回；零上限直接返回，避免建立一次没有必要的适配。

package main

import (
    "fmt"
    "iter"
)

// Samples 按需交付序号；closed 用于说明生产端清理的归属。
func Samples(count int, closed *bool) iter.Seq[int] {
    return func(yield func(int) bool) {
        defer func() { *closed = true }()
        for i := 0; i 

根据示例语义，消费的是 0、1、2，合计应为 3。Consume 返回前会执行 stop，生产端的延迟清理会把 closed 设为 true。这是供读者理解代码的预期推导，不是本机实测输出。

limit 约束的是消费请求数量。Samples 中没有缓存，也没有在 yield 之前预生成全部结果；其他数据源可能有自己的预取行为，不能把“调用 next 三次”理解成底层一定只做了三次 I/O。

提前结束后生产端怎样完成清理

读者问：已经达到 limit，直接 return 不就结束了吗？

消费函数结束不等于生产迭代器已经走到末尾。在没有读尽的情况下需要 stop，让生产端退出当前迭代。本例让清理动作写在源函数的 defer 中，消费端负责结束信号；两侧职责不互相替代。

defer 应放在这个 Consume 作用域，不能在处理很多序列的外层函数里不断积累 stop，等所有批次结束才统一执行。如果为多条序列各建一个 Pull，可抽取单条消费函数，让每次调用自己的清理都及时结束。

少建整批切片是否等于更少分配

读者问：没有结果切片，能否直接说 Pull 比收集更快、更省内存？

只能先说本例不建立一个保存全部消费结果的切片。总分配还包括适配状态、闭包、源数据与业务对象等，实际执行时间也取决于每次交付的成本。与直接 range 相比，Pull 可能增加额外成本；如果只是普通顺序消费，应优先保留更直接的循环。

如需判断性能收益，应让三种实现消费相同的数据数量、执行相同处理逻辑，再比较每次操作时间、字节数与分配次数。提前只读三项的版本与全量收集七项的版本完成的工作不同，不能把两者的差值全归功于 Pull。本篇没有提供测量值。

空序列、错误与并发调用如何处理

空序列是一个合法但不交付元素的函数；第一次 next 就会给出无有效值的结果。本例对 nil 序列单独返回参数错误，避免把函数不存在混同于序列为空。返回值等于零也不代表结束，是否有效要看 ok。

不要从多个 goroutine 同时调用同一组 next 和 stop。本文的 closed 指针只是同一消费过程中的演示标记，没有增加并发访问能力。若将示例扩展到多任务消费，各任务应有独立迭代状态与明确的数据所有权。

next 的 ok 表示是否有元素，不是源错误。源若可能失败，要在原接口中显式承载错误，并由消费端处理；Pull 不会把业务错误变成一个新的 error 返回值。源发生 panic 也不能指望 Pull 自动替你转换成普通错误。

stop 结束的是本次适配的迭代，不保证它能中断源函数内部一个任意阻塞调用。数据库、网络或文件的取消与关闭仍需源接口自行约定。本文没有外部句柄，故不添加无关的取消代码。

相关问题

可以把 next 保存起来供以后使用吗？可以设计长寿命对象，但必须同时安排 stop 的拥有者。本文用函数作用域减少遗忘清理的机会。

零上限时 closed 为什么不要求变成 true？Consume 直接返回，没有开始消费源函数。这个标记只说明已启动的生产函数是否结束，不是资源句柄。

如果后面仍要把所有值存到切片呢？那就没有消除结果切片存储，是否采用 Pull 应由读取接口需要决定。

让一次消费拥有一组 next 与 stop，并在真实业务需要逐项请求时使用它，比把适配器当作通用性能优化更容易维护。