Class: Coroutine

Inherits:
Object show all
Defined in:
lib/carat/coroutine.rb

Overview

Coroutine

Coroutines are program components like subroutines. Coroutines are more generic and flexible than subroutines, but are less widely used in practice. Coroutines were first introduced natively in Simula. Coroutines are well suited for implementing more familiar program components such as cooperative tasks, iterators, infinite lists, and pipes.

Example

count = (ARGV.shift || 1000).to_i
input = (1..count).map { (rand * 10000).round.to_f / 100}
Producer = Coroutine.new do |me|
  loop do
    1.upto(6) do
      me[:last_input] = input.shift
      me.resume(Printer)
    end
    input.shift # discard every seventh input number
  end
end
Printer = Coroutine.new do |me|
  loop do
    1.upto(8) do
      me.resume(Producer)
      if Producer[:last_input]
        print Producer[:last_input], "\t"
        Producer[:last_input] = nil
      end
      me.resume(Controller)
    end
    puts
  end
end
Controller = Coroutine.new do |me|
  until input.empty? do
    me.resume(Printer)
  end
end
Controller.run
puts

Author

  • Florian Frank

History

$Id: coroutine.rb,v 1.0.0 2004/12/01 transami Exp $

Constant Summary collapse

VERSION = 
"1.0.0"

Instance Method Summary collapse

Constructor Details

#initialize(data = {}) {|_self| ... } ⇒ Coroutine

Returns a new instance of Coroutine.

Yields:

  • (_self)

Yield Parameters:

  • _self (Coroutine) —

    the object that the method was called on



58
59
60
61
62
63
64
65
 
# File 'lib/carat/coroutine.rb', line 58

def initialize(data = {})
  @data = data
  callcc do |@continue|
    return
  end
  yield self
  stop
end

Instance Method Details

#[](name) ⇒ Object 



90
91
92
 
# File 'lib/carat/coroutine.rb', line 90

def [](name)
  @data[name]
end

#[]=(name, value) ⇒ Object 



94
95
96
 
# File 'lib/carat/coroutine.rb', line 94

def []=(name, value)
  @data[name] = value
end

#resume(other) ⇒ Object 



79
80
81
82
83
 
# File 'lib/carat/coroutine.rb', line 79

def resume(other)
  callcc do |@continue|
    other.continue(self)
  end
end

#run ⇒ Object 



69
70
71
72
73
 
# File 'lib/carat/coroutine.rb', line 69

def run
  callcc do |@stopped|
    continue
  end
end

#stop ⇒ Object 



75
76
77
 
# File 'lib/carat/coroutine.rb', line 75

def stop
  @stopped.call
end