iter.Pull2 适配双值迭代器的资源释放

把 iter.Seq2 交给 iter.Pull2 后，最稳妥的资源释放写法只有两件事：生产者在自己的函数体里用 defer 清理它创建的资源；调用方拿到 stop 后立即写 defer stop()。前者决定“清理什么”，后者保证提前不再调用 next 时生产者仍能结束。

如果一直拉取到 next 返回 ok=false，序列已经自然结束；如果中途 return、break 或只取前几项，就必须调用 stop。官方还明确说明：重复调用 stop 是允许的，在序列结束后调用也安全。

官方文档：https://pkg.go.dev/iter

先划清资源所有权

Pull2 的职责是把推送式的 Seq2[K,V] 适配成拉取式的 next() (K,V,bool) 与 stop()。它不会自动知道业务资源是什么，也不能代替文件的 Close、计时器的 Stop 或后台任务的取消函数。

因此要把责任分成三层：

• 消费端：持有 next 和 stop，决定何时不再要数据。
• 适配层：iter.Pull2 在拉取调用与 yield 之间建立桥接。
• 生产端：Seq2 创建资源，并在函数返回前执行自己的 defer 清理。

让 Seq2 在资源旁边注册清理动作

下面用一个持续产生“序号 + 时间”的双值迭代器演示。它内部创建 time.Ticker，所以也由它负责停止计时器。这个序列没有天然终点，调用方只要不再读取，就一定要让生产者返回。

package main

import (
    "iter"
    "time"
)

// Ticks 返回一个单次使用的双值迭代器：序号和触发时间。
// 计时器由生产者创建，因此也在生产者返回时释放。
func Ticks(interval time.Duration) iter.Seq2[int, time.Time] {
    return func(yield func(int, time.Time) bool) {
        ticker := time.NewTicker(interval)
        defer ticker.Stop() // 无论自然结束还是被停止，都释放计时器资源

        for index := 1; ; index++ {
            at := 

把清理语句放在资源创建处附近，可以直接看出所有权，也能覆盖生产者内部新增的返回分支。对于文件、压缩流或响应体，同样应让拥有它的生产者注册相应清理。

拿到 stop 后立即交给 defer

业务只想取前三次触发时间。关键不是循环写法，而是 stop 的托管位置：它必须紧跟在 Pull2 后面，不能等到循环之后再补。

func FirstThree(interval time.Duration) []time.Time {
    next, stop := iter.Pull2(Ticks(interval))
    defer stop() // 提前 return、循环结束或后续新增错误分支都会执行

    values := make([]time.Time, 0, 3)
    for len(values) 

这段代码不会把 stop 当成 Ticker.Stop。调用方只发出“结束拉取”的信号；生产者收到停止后从 yield 返回，再执行自己的 defer ticker.Stop()。这条所有权链才是完整的资源释放。

三种退出场景共用一套收尾规则

完整工作流可以按退出条件理解，而不必为每个分支设计不同清理代码。

官方文档允许在结束后重复调用 stop，所以“总是立即 defer”比在多个分支中判断是否需要停止更简单。相反，next 与 stop 不应被多个 goroutine 同时调用；需要跨 goroutine 协调时，应在外层串行化访问，而不是把 Pull2 当作并发队列。

把模式迁移到文件和网络流

迁移时不要只复制 defer stop()，还要确认资源确实位于 Seq2 的控制范围内。下面是一份可复用检查顺序：

1. 资源由谁创建，就由谁注册 defer Close/Stop/Cancel。
2. Seq2 的生产循环在 yield 返回 false 时立即 return。
3. 调用方取得 next, stop 后立刻 defer stop()。
4. 调用方只在 ok=true 时使用两个返回值。
5. 同一组 next/stop 保持单 goroutine 串行访问。

如果资源在创建 Seq2 之前已经打开，并且生产者没有接管所有权，那么 stop 不会凭空替你关闭它。此时要么把资源创建移进生产者，要么由外层另行 defer Close，并在 API 文档中明确谁负责释放。

常见误区与速查表

相关问题

序列已经耗尽，还需要调用 stop 吗？

不是为了再次释放资源，但保留 defer stop() 完全合法。官方文档说明，在 next 已返回 false 后调用 stop 仍然有效且安全。

调用 stop 后还能继续调用 next 吗？

可以调用，但只会持续得到两个零值和 false，不应再把结果当作有效数据。

为什么不直接用 for range？

能够顺序消费时，for range 通常更自然。只有需要按需拉取、交错读取多个序列、做前瞻或由外部逻辑决定何时取下一项时，才更适合使用 Pull2。

文件关闭错误应该在哪里处理？

如果业务必须获得关闭错误，应让生产者把终态错误存入一个明确的状态对象，并在生产者完成后读取；不要假设 stop 的返回值会携带错误，因为它没有返回值。

记住一个可复用的判断：stop 负责让迭代器结束，生产者的 defer 才负责释放具体资源。只要这两层都存在，Pull2 在正常耗尽和提前退出时都能可靠收尾。