iter.Seq 提前停止后为什么生产者仍在运行

使用 Go 的 iter.Seq 时，消费者的 break 并不会“杀掉”一个独立的生产协程。它先让本次 yield 返回 false，生产者是否马上停下，取决于生产者有没有检查这个返回值。若生产者忽略信号继续调用 yield，就可能继续做无效工作，甚至触发迭代器契约规定的错误。

iter.Seq 提前停止时，消费者的 break 需要通过 yield 返回 false 传给生产者；生产者必须检查这个返回值并停止继续产出。

iter.Seq 的停止责任在 yield 返回值

iter.Seq[V] 本质上是一个接收 func(V) bool 的函数。消费者写下 break 后，运行时会让当前回调返回 false，但它不会替你的生产者补写 return。因此，真正的停止点在生产者循环。

一个安全的生产者应该把返回值当作边界检查：

func Numbers(max int) iter.Seq[int] {
    return func(yield func(int) bool) {
        for i := 0; i 

如果把 if !yield(i) 去掉，表面上仍能打印前几个值，但停止语义已经丢失。官方契约明确规定，yield 一旦返回 false，后续再次调用就是错误；所以不要用“消费者已经 break，应该没事”来掩盖生产者的失控。

为什么看起来像生产者还在运行

排查时先分清三种情况。第一，生产者在同一个调用栈里同步执行：只要检查了 false，它会返回，break 后不会继续下一轮。第二，生产者在 Seq 内启动了 goroutine：break 只结束当前消费关系，后台 goroutine 仍需通过取消信号自行退出。第三，使用了 iter.Pull：它内部需要维护拉取状态，提前离开却不调用 stop，就可能让等待中的工作和资源无法及时回收。

iter.Pull 提前结束必须调用 stop

当代码需要一次取一个值，可以用 iter.Pull 得到 next 和 stop。这里的 stop 不是可有可无的“优化按钮”，而是消费者没有读完整个序列时的生命周期出口。

func FirstMatch[V any](seq iter.Seq[V], match func(V) bool) (V, bool) {
    next, stop := iter.Pull(seq)
    // 提前返回时也要通知迭代器结束，避免后台状态悬挂。
    defer stop()

    for {
        value, ok := next()
        if !ok {
            var zero V
            return zero, false
        }
        if match(value) {
            return value, true
        }
    }
}

读到 ok == false 后，调用 stop 仍然是合法的；多次调用也允许，因此用 defer 最稳妥。不要让多个 goroutine 同时调用 next 或 stop，这属于另一条并发边界。

自建异步生产者要把取消路径接通

如果业务需要在 Seq 内启动后台工作，不要把 range 的 break 当成对任意 goroutine 的广播。应把取消信号写进生产循环，并保证发送、关闭和资源释放都有出口。

func FromChannel(ctx context.Context, input 

这里的 ctx 是异步来源的补充控制面；对于普通同步 Seq，最重要的仍是检查 yield。若来源还持有文件、连接或锁，应把释放动作放到生产者确定返回的路径中，不能只在消费端记录“已停止”。

用五项检查确认没有假停止

1. 正常读完整个序列，确认生产者能自然返回。
2. 第一项就 break，确认生产者没有第二次调用 yield。
3. Pull 只取一项，确认 defer stop() 覆盖所有返回路径。
4. 异步来源触发取消，确认 goroutine、channel 和外部资源都能结束。
5. 不要并发调用同一组 next/stop，也不要把日志里的“发送过”误判为“消费者仍在接收”。

相关问题

range over iter.Seq 的 break 会自动关闭 channel 吗？

不会。它只影响当前迭代回调；channel 或 goroutine 的退出必须由生产者检查返回值或监听取消信号完成。

yield 返回 false 后还能做清理吗？

可以，生产者应停止继续产出，再执行自己的清理逻辑并返回；不能再次调用 yield。

iter.Pull 一定要调用 stop 吗？

未消费到序列结束时应调用，最简单的写法是拿到 next 后立即 defer stop()；正常读完后调用也合法。