Go iter.Seq 怎样让消费者提前停止生产

结论先说：iter.Seq 让消费者提前停止生产，靠的不是消费者去“关闭”一个对象，而是 yield func(V) bool 的返回值。消费者在 for range 中执行 break 后，语言生成的 yield 会返回 false；生产方必须检查这个结果并立刻 return，把文件、锁或其他资源交给既有的收尾逻辑。

Go 官方资料：https://pkg.go.dev/iter

语法说明：https://go.dev/ref/spec#For_statements

先把 Seq 和 yield 的职责分开

Go 1.23 起，函数可以作为 range 的迭代来源，但它的形状受到限制。单值迭代器可以写成 func(yield func(V) bool)，标准库把这个形状命名为 iter.Seq[V]。Seq 是生产方，yield 是消费者与生产方之间的停止协议。

因此，下面两件事不是一回事：

最容易写错的是把 yield(v) 当成只负责传值的回调，然后无条件继续读取源数据。这样消费者虽然已经停止，生产方仍可能继续读文件、遍历树或构造下一条记录。

为什么 break 能让 iter.Seq 停止生产

消费者通常只需要写熟悉的 range：

package main

import (
	"fmt"
	"iter"
)

// Numbers 返回一个可以被 range 消费的单值迭代器。
func Numbers(limit int) iter.Seq[int] {
	return func(yield func(int) bool) {
		for n := 0; n 

这段代码中，break 不会直接调用生产方的某个 Stop 方法。语言运行时会让迭代协议中的 yield 表达“不要再继续”，生产方看到 false 后返回。生产方如果忽略这个返回值，在下一轮继续调用 yield，就违反了 Seq 的约定。

这个约定也解释了为什么生产循环的判断要紧贴调用点：只有这样，源数据读取、发送或递归遍历才会在停止信号出现后马上收敛。不要把 yield 的结果暂存在一个与生产循环无关的状态变量里，再到很远的位置才处理。

手写 Seq 时要怎样把停止信号传到收尾

如果 Seq 包住文件、锁、网络响应或临时缓冲区，资源释放应该由生产函数自己的 defer 负责。false 分支需要结束生产函数，但不需要重复写一套释放代码：

func Lines(data []string) iter.Seq[string] {
	return func(yield func(string) bool) {
		resource := acquireResource() // 中文注释：示意生产方持有需要收尾的资源
		defer resource.Close()        // 中文注释：无论正常结束还是提前停止都执行清理

		for _, line := range data {
			if !yield(line) { // 中文注释：消费者不再接收时，停止读取后续数据
				return // 中文注释：返回触发 defer，统一完成资源收尾
			}
		}
	}
}

这里的 acquireResource 和 Close 只是说明资源生命周期的占位名称，实际项目应替换为真实资源类型和错误处理。关键结构有两个：资源取得后尽早注册 defer，以及每次调用 yield 后立即检查 bool。不要把清理放在遍历完成后的单独分支，因为提前 return 时那条路径可能根本不会执行。

如果生产函数还需要向上层返回错误，iter.Seq 本身没有错误返回位。可以把错误状态放在闭包可见的位置，或改用能表达错误的更高层 API；但无论采用哪种封装，停止信号和资源收尾都不能被吞掉。

直接调用 Seq 和 iter.Pull 的边界不同

普通 for range 会替消费者处理提前退出；但如果你手动调用一个 Seq，就要自己实现 yield，并且自己遵守 false 约定：

func consume(seq iter.Seq[int], limit int) {
	count := 0
	seq(func(v int) bool {
		fmt.Println(v) // 中文注释：处理当前值
		count++
		return count 

而 iter.Pull 把 push 形式转换成一次取一个值的 pull 形式，并返回 next 与 stop。当调用方没有读到序列末尾就结束时，应调用 stop，通常写成 defer stop()。这与 range 自动让 yield 返回 false 的路径不同：pull 形式把停止责任显式交给调用方。

func firstMatch(seq iter.Seq[string], want string) (string, bool) {
	next, stop := iter.Pull(seq)
	defer stop() // 中文注释：提前返回或正常结束都通知底层生产方收尾

	for {
		value, ok := next()
		if !ok {
			return "", false // 中文注释：序列耗尽，未找到目标
		}
		if value == want {
			return value, true // 中文注释：提前返回，由 defer stop 负责停止
		}
	}
}

选择方式可以按一个简单规则判断：只需顺序消费并允许 break，优先用 for range；需要手工回调时，确保回调返回 false 后生产方立即 return；需要逐个拉取、并行比较或在多个位置提前返回时，使用 iter.Pull 并保留 stop。

排查提前停止不生效时看这三处

1. 看生产循环是否直接判断了 yield(v) 的 bool，而不是无条件继续下一轮。
2. 看消费者的 break 或手写回调的 false 是否真的覆盖了想停止的分支。
3. 看资源是否在生产函数内注册了 defer，或在 pull 形式中是否始终保留 stop。

如果 Seq 来自第三方库，还要确认它是否遵守标准迭代器契约：返回 false 后不能继续调用 yield。这个判断比“循环看起来已经 break”更重要，因为消费者只能表达停止意图，生产方是否响应决定了资源和计算是否真正停下来。

常见问题

yield 返回 false 后还能继续调用吗？

不能。false 表示消费者不再需要后续值，生产方应停止调用 yield 并返回；继续调用会违反迭代器协议。

break 会自动关闭文件或网络连接吗？

break 只触发迭代停止协议，不知道你的资源是什么。文件、连接或锁仍应由生产方的 defer 或明确的收尾逻辑负责关闭。

iter.Pull 为什么还要 stop？

Pull 调用方可能在序列耗尽前返回，单靠 next 没有位置把 false 传回 push 生产方，所以需要显式 stop。把它写进 defer 可以覆盖多个返回分支。

相关资料：https://pkg.go.dev/iter、https://go.dev/blog/range-functions、https://go.dev/ref/spec#For_statements。