Contents

require("actor")
class Actor {
  alias_method: '! for_ruby: '<<
}

# Execute with Rubinius: rbx ex1.rb

def error_loop: block{
  try {
    loop: block
  } catch Exception => ex {
    ex message println
    ex backtrace join: "\n"
  }
}

pong = nil
ping = Actor spawn() {
  error_loop: {
    count = Actor receive()
    "." print
    { return count println } if: (count > 1000)
    pong ! (count + 1)
  }
}
pong = Actor.spawn() {
  error_loop: {
    count = Actor receive()
    "-" print
    { return count println } if: (count > 1000)
    ping ! (count + 1)
  }
}
ping ! 1

# Let the actors process while the main thread sleeps...
Thread sleep: 1

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fancy-0.3.3	examples/actor.fy