[ruby-list:34953] Re: Thread by callcc

In article <[e-mail]>,
  Tanaka Akira <[e-mail]> writes:

> coroutine.rb は次のようなものです。

う、間違えました。SizedQueue を使わずに Mutex に書き換えている途中のも
のを出してしまいました。こっちが正しい(動く)ものです。

--- coroutine.rb ---
require 'thread'

class Thread
  def queue
    @queue = SizedQueue.new(1) unless defined? @queue
    @queue
  end

  def resume(val=nil)
    self.queue.enq val
    Thread.current.queue.deq
  end
end

class Coroutine < Thread
  def initialize(&block)
    caller = Thread.current
    super() {
      caller.resume block.call(self.queue.deq)
    }
  end
end

if $0 == __FILE__
  main = Thread.current
  c = Coroutine.new {|a|
    p a
    p 2
    p main.resume(2.5)
    p 4
    p main.resume(4.5)
    p 6
    p main.resume(6.5)
  }
  p 1
  p c.resume(1.5)
  p 3
  p c.resume(3.5)
  p 5
  p c.resume(5.5)
end
----
-- 
[田中 哲][たなか あきら][Tanaka Akira]
「ふえろ! わかめちゃん作戦です$(C⊇」(Little Worker, 桂遊生丸)