From: Tanaka Akira <akr@...17n.org>
Date: 2002-04-21T14:51:36+09:00
Subject: [ruby-list:34953] Re: Thread by callcc

In article <hvon0vxwqvb.fsf@coulee.a02.aist.go.jp>,
  Tanaka Akira <akr@m17n.org> writes:

> coroutine.rb $B$O<!$N$h$&$J$b$N$G$9!#(B

$B$&!"4V0c$($^$7$?!#(BSizedQueue $B$r;H$o$:$K(B Mutex $B$K=q$-49$($F$$$kESCf$N$b(B
$B$N$r=P$7$F$7$^$$$^$7$?!#$3$C$A$,@5$7$$(B($BF0$/(B)$B$b$N$G$9!#(B

--- 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
----
-- 
[$BEDCf(B $BE/(B][$B$?$J$+(B $B$"$-$i(B][Tanaka Akira]
$B!V$U$($m(B! $B$o$+$a$A$c$s:n@o$G$9$(C"=$B!W(B(Little Worker, $B7KM7@84](B)