使用代码块创建的枚举器实际如何运行

Question

这只是一个简单的问题，y.<<方法如何能够停止代码块的中间执行？

我预计代码块只运行一次并且永远不会在中间停止：/

e = Enumerator.new do |y|
    puts "Ruby"
    y << 1
    y << 2
    puts "Ruby"
    y << 3
end

puts e.each.next
puts e.each.next
puts e.each.next
e.rewind
puts e.each.next
puts e.each.next
puts e.each.next

Answer 1

几乎所有 Ruby 实现都是免费软件和开源的，因此您只需查看源代码即可了解它是如何实现的。

在 Rubinius 中，最有趣的部分是 Enumerator::Iterator#reset，实现于 < a href="https://github.com/rubinius/rubinius/blob/master/core/enumerator.rb#L491-L498" rel="nofollow noreferrer">core/enumerator.rb：

@fiber = Fiber.new stack_size: STACK_SIZE do
  obj = @object
  @result = obj.each { |*val| Fiber.yield *val }
  @done = true
end

和 Enumerator::Iterator#next:

val = @fiber.resume

TruffleRuby 的实现非常相似，您可以在 src/main/ruby/truffleruby/core/enumerator.rb：

class FiberGenerator
  # irrelevant methods omitted

  def next
    reset unless @fiber

    val = @fiber.resume

    raise StopIteration, 'iteration has ended' if @done

    val
  end

  def reset
    @done = false
    @fiber = Fiber.new do
      obj = @object
      @result = obj.each do |*val|
        Fiber.yield(*val)
      end
      @done = true
    end
  end
end

JRuby 也非常相似，正如您在 核心/src/main/ruby/jruby/kernel/enumerator.rb：

class FiberGenerator
  # irrelevant methods omitted

  def next
    reset unless @fiber&.__alive__

    val = @fiber.resume

    raise StopIteration, 'iteration has ended' if @state.done

    val
  end

  def reset
    @state.done = false
    @state.result = nil
    @fiber = Fiber.new(&@state)
  end

end

MRuby 的实现非常相似，您可以在 mrbgems/mruby-enumerator/mrblib/enumerator.rb。

YARV 也使用 Fiber，如 enumerator.c，例如这里：

static void
next_init(VALUE obj, struct enumerator *e)
{
    VALUE curr = rb_fiber_current();
    e->dst = curr;
    e->fib = rb_fiber_new(next_i, obj);
    e->lookahead = Qundef;
}

static VALUE
get_next_values(VALUE obj, struct enumerator *e)
{
    VALUE curr, vs;

    if (e->stop_exc)
    rb_exc_raise(e->stop_exc);

    curr = rb_fiber_current();

    if (!e->fib || !rb_fiber_alive_p(e->fib)) {
    next_init(obj, e);
    }

    vs = rb_fiber_resume(e->fib, 1, &curr);
    if (e->stop_exc) {
    e->fib = 0;
    e->dst = Qnil;
    e->lookahead = Qundef;
    e->feedvalue = Qundef;
    rb_exc_raise(e->stop_exc);
    }
    return vs;
}

所以，毫不奇怪， Enumerator 是使用 许多 Ruby 实现中的Fiber。 Fiber 本质上只是 Ruby 的半协程的名称，当然，协程是实现 生成器和迭代器。例如，CPython 和 CoreCLR 也使用协程实现生成器。

一个例外似乎是 Opal。我的假设是 Opal 将使用 ECMAScript 生成器实现 Ruby Enumerator，但看起来情况并非如此。 Opal 中 Ruby Enumerator 的实现可在 opal/corelib/enumerator.rb, opal/corelib/enumerator/generator.rb和 opal/corelib/enumerator/yielder.rb 在 opal/corelib/runtime.js，但不幸的是，我并不完全理解它。不过，它似乎没有使用 Ruby Fiber 或 ECMAScript 生成器。

顺便说一句，您对 Enumerator 的使用有点奇怪：您调用 Enumerator#each 六次（不带块），但调用 Enumerator#each 不带块只会返回 Enumerator本身：

每个 → 枚举

根据此Enumerator 的构造方式迭代块。如果没有块并且没有给出参数，则返回 self。

因此，换句话说，所有对 Enumerator#each 的调用都只是无操作。调用 Enumerator#next< 会更有意义/code>直接：

puts e.next
puts e.next
puts e.next
e.rewind
puts e.next
puts e.next
puts e.next