[ruby-dev:28147] Re: ia64-hpux11.23/socket.sl: this executable file can't load extension libraries (LoadError)

山本です。

>もし予測が正しければそれは callcc が癌なので、generator.rb
>を callcc じゃなくて thread で実装するのがいいのではないかと
>思っています。

同感です。（callcc は危険だと思う --;;）

Thread.critical じゃなくて Mutex を使うべきだとか、
色々ありそうですが、とりあえずこんな感じで動きました。

一応 [ruby-dev:25674] にも対応したつもりです。

Thread.abort_on_exception = true

class Generator
  include Enumerable

  def initialize(enum = nil, &block)
    if enum
      @block = proc{|g| enum.each{|value| g.yield value}}
    else
      @block = block
    end
    @index = 0
    @queue = []
    @loop_thread = Thread.new do
      Thread.stop
      Thread.critical = true
      begin
        @block.call(self) # exception safe?
      ensure
        @main_thread.wakeup
        Thread.critical = false
      end
    end
  end

  def yield(value)
    if Thread.current != @loop_thread
      raise RuntimeError.new("Generator#yield must be called in Generator.new(){|g| ... }")
    end
    @queue << value
    @main_thread.wakeup
    Thread.stop
    Thread.critical = true
  end

  def end?
    if @queue.empty?
      Thread.critical = true
      @main_thread = Thread.current
      begin
        @loop_thread.wakeup
        Thread.stop
      rescue ThreadError
        # ignore
      ensure
        @main_thread = nil
        Thread.critical = false
      end
    end
    @queue.empty?
  end

  def current
    raise EOFError.new("no more elements available") if end?
    @queue.first
  end

  def next
    raise EOFError.new("no more elements available") if end?
    @index += 1
    @queue.shift
  end

  def next?
    !end?
  end

  def index
    @index
  end

  def pos
    @index
  end

  def rewind
    initialize(nil, &@block) if @index.nonzero?
    self
  end

  def each
    rewind
    until end?
      yield self.next
    end
    self
  end

end