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

In article <4.3.2-J.20020418180027.03565ca0@blade.nagaokaut.ac.jp>,
  Shin-ichiro HARA <sinara@blade.nagaokaut.ac.jp> writes:

> $B;v$N5/$3$j$ON)@P$5$s$,(B [rubyist:1340] $B$G!"$b$&$A$g$C$H(B Continuation
> $B$N1~MQNc$GNI$$$N$r$"$2$^$7$g$&!"$H$$$&OC$@$C$?$s$G$9$,!"?70f$5$s$,!"(B
> Continuation $B$J$s$+$$$i$J$$$s$8$c$J$$$+$H!"K=8@(B:-)$B$rEG$-!"$7$^$$$K$O(B
> $B$^$D$b$H$5$s$b!"(BRite $B$8$c$d$a$A$c$&$+$b!"$J$I$H8@$&;OKv!#0lJ}!"(BTosh 
> $B$5$s$,!"(B[rubyist:1352] $B$G!"(Bchoose $B$H$$$&(B Non-deterministic Programming
> $B$r<B8=$9$kHs>o$K6=L#?<$$Nc$r$"$2$F!"$G$b$A$g$C$H$^$:$$$H$3$m$b$"$k$s(B
> $B$@!"$H$$$&OC$G$7$?!#(B

$B8D?ME*$K$O(B callcc $B$N$h$&$J2x$7$$5!G=$OBg9%$-$J$N$G$9$,!"CN9g$$$N(B
callcc $BM-32O@$b$b$C$H$b$@$H;W$&$3$H$b$"$j!"BVEY$r7h$a$+$M$F$$$?$j$7$^(B
$B$9!#(B

> $BA0CV$-$,D9$/$J$j$^$7$?$,!"$3$N(B CoThread $B$H$$$&$N$,!"$+$J$jNI$/=PMh$F(B
> $B$$$k$+$b$7$l$J$$!"$H;W$&$N$G@bL@$7$^$9!#(B

$B$3$l$C$FC1$K%m%C%/$r=q$+$J$/$F$$$$$H$$$&$@$1$G$O(B?

$B$@$H$7$?$i!"$`$7$m%9%l%C%I$N0!<o$H$7$F%3%k!<%A%s$N%5%]!<%H$rF~$l$k$H$$(B
$B$&<j$b$"$k$N$G$O(B?

$B$H!";W$C$?$N$G!";n$7$F$_$^$7$?!#(B

$B%3%k!<%A%s$r(B coroutine.rb $B$H$$$&$N$G(B($BFbIt$G%9%l%C%I$r;H$C$F(B)$B<BAu$7!"(B

> (2) $BJ?9T(B each
> (3) $BFbIt%$%F%l!<%?$N30It%$%F%l!<%?$X$NJQ49(B

$B$HF1$8(B API $B$r%3%k!<%A%s$G:n$j$J$*$7$F$_$^$7$?!#(B

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

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

class Thread
  def mutex
    @mutex = Mutex.new unless defined? @mutex
    @mutex
  end

  def resume(val=nil)
    self.mutex.lock
    @val = val
    self.run
    Thread.current.mutex.unlock
    Thread.stop

    self.queue.enq val
    Thread.current.queue.deq
  end
end

class Coroutine < Thread
  def initialize(&block)
    caller = Thread.current
    super() {
      Thread.stop

      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
------

$B$G!"$3$l$r;H$&$H(B sync-each.rb $B$H(B generator.rb $B$O<!$N$h$&$K=q$1$^$9!#(B

--- sync-each.rb ---
require 'coroutine'

class SyncEach
  include Enumerable

  def initialize(*es)
    @size = es.first.size
    @cs = es.map {|e|
      Coroutine.new {|t|
        e.each {|x|
	  t = t.resume x
	}
      }
    }
  end

  def each
    @size.times {
      yield @cs.map {|c| c.resume(Thread.current)}
    }
  end
end

if $0 == __FILE__
   foo = SyncEach.new(0..3, 10..13, 20..23)
   foo.each do |a|
     p a
   end
end
------

--- generator.rb ---
require 'coroutine'

class Generator
  def initialize(enum, iter = :each, eoi = :eoi)
    @c = Coroutine.new {|t|
      enum.send(iter) {|x|
        t = t.resume x
      }
      t.resume(eoi)
    }
  end

  def next
    @c.resume(Thread.current)
  end
end

if $0 == __FILE__
   g = Generator.new(0..3)

   while :eoi != (x = g.next)
     p x
   end

   puts

   module Fibonacci
     def self.each
       a, b = -1, 1
       loop do
        a, b = b, a + b
        yield b
       end
     end
   end

   g = Generator.new(Fibonacci)
   while (x = g.next) < 200
     p x
   end
end
------

$B9T?t$rHf3S$7$F$_$k$H$o$+$j$^$9$,!"$[$H$s$IF1$8$G$9!#(B

$B$H$$$&$o$1$G!"(B

> $B$=$l$>$l!"(BThread $B$r;H$&$H$+$J$j5$$r;H$o$J$1$l$P$J$i$J$$$H$3$m$,!"(B
> $B$:$$$V$sAGD>$K=q$1$F$$$k$H;W$$$^$9!#(B

$B$H$$$&<gD%$O!"$d$O$j!"C1$K%m%C%/$r5$$K$7$J$/$F$$$$$H$$$&$H$3$m$K5/0x$9(B
$B$k$N$G$"$m$&$H$$$&7kO@$K;j$j$^$7$?!#(B

> $B$3$s$JIw$K%i%$%V%i%j$r=<<B$5$;$F$$$1$P!"(Bcallcc $B$b@8$-1d$S$i$l$k!)(B

$B;W$&$K!"%3%k!<%A%s$G$O:Q$^$J$$MQES$rLO:w$7$J$$$H@8$-1d$S$i$l$J$$$s$8$c(B
$B$J$$$G$7$g$&$+!#$H$3$m$,!"$=$&$$$&(B

In article <4.3.2-J.20020419184737.031a7f58@blade.nagaokaut.ac.jp>,
  Shin-ichiro HARA <sinara@blade.nagaokaut.ac.jp> writes:

> $B$3$N(B Thread by callcc $B$N%U%l!<%`$K>h$i$J$$(B callcc $B$NNc$r9M$($F(B
> $B$_$?$N$G$9$,!"$3$&$$$&%P%C%/%H%i%C%-%s%0%7%9%F%`$,3:Ev$9$k$h$&(B
> $B$G$9!#(B

$B$H$$$&$h$&$J$d$D$r%5%]!<%H$9$k$K$O8@8l$*$h$S%i%$%V%i%j$N<j8|$$;Y1g$,I,(B
$BMW$G$9!#(B

$B$H$/$K%i%$%V%i%j$OLq2p$G!"$3$&$$$&$N$r0BA4$K;H$&$K$O!"A4$F$N(B($B$"$k$$$O(B
$B>/$J$/$H$bBgItJ,$N(B)$B%i%$%V%i%j$,!">o$K%/%i%$%"%s%H$N%3!<%I$r<B9T$7$?$i(B
$B$=$3$G7QB3$rJ]B8$5$l$F!"2?2s$b:FF~$7$F$/$k$H$$$&2DG=@-$r9MN8$7$F=q$+$J(B
$B$$$H$$$1$^$;$s!#$3$l$O%i%$%V%i%j$N:n<T$K$H$C$FIi2Y$,9b$9$.!"$7$+$b!"$=(B
$B$l$KBP$7$FMQES$,>/$J2a$.$k!"$H$$$&$N$,CN9g$$(B(g$B?7It$5$s(B)$B$N(B callcc $BM-32(B
$BO@$G$9!#(B

$B$J$+$J$+H?O@$9$k$N$OFq$7$$$G$9!#(B

$BM}O@E*$J0UL#9g$$$G!"(Bprimitive $B$,>/$J$/$J$k$+$i$h$$!"$H$$$&$N$K$OF10U$7(B
$B$F$/$l$k$s$G$9$,!"$=$l$,<B:]E*$J%W%m%0%i%_%s%0$K7k$SIU$/$+$H$$$&$H$J$+(B
$B$J$+Fq$7$$$o$1$G$9!#(B

$B$J$*!"(BRuby $B$K$O(B dynamic-wind $B$,$J$$$N$G%i%$%V%i%j$r(B callcc safe $B$K$9$k(B
$B$N$OFq$7$$$G$7$g$&$M!#$$$d!"$"$C$F$bFq$7$$$H$$$&5$$O$7$^$9$,!#(B
-- 
[$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)