Class: Rubinius::Actor

actor/filter.rb - actor message filters

          2007-2011  Evan Phoenix <evan@fallingsnow.net>

Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:

Redistributions of source code must retain the above copyright notice, thi slist of conditions and the following disclaimer.
Redistributions in binary form must reproduce the above copyright notice this list of conditions and the following disclaimer in the documentatio and/or other materials provided with the distribution.
Neither the name of the Evan Phoenix nor the names of its contributors may be used to endorse or promote products derived from this software without specific prior written permission.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

Methods

<< check_for_interrupt current link lookup new notify_exited notify_link notify_unlink receive register send send_exit spawn spawn_link trap_exit trap_exit= unlink

Classes and Modules

Module Rubinius::Actor::ANY
Class Rubinius::Actor::DeadActorError
Class Rubinius::Actor::Filter

Constants

ANY = Object.new

External Aliases

new	->	private_new
spawn	->	new
trap_exit	->	trap_exit?
lookup	->	[]
register	->	[]=

Public Class methods

check_for_interrupt()

Polls for exit notifications

current()

link(actor)

Link the current Actor to another one.

lookup(name)

Lookup a locally named service

new() {|self| ...}

receive( {|filter| ...}

Waits until a matching message is received in the current actor‘s mailbox, and executes the appropriate action. May be interrupted by exit notifications.

send_exit(recipient, reason)

Send a "fake" exit notification to another actor, as if the current actor had exited with reason

spawn(*args, &block)

Spawn a new Actor that will run in its own thread

spawn_link(*args, &block)

Atomically spawn an actor and link it to the current actor

trap_exit()

Is the Actor trapping exit?

trap_exit=(value)

Actors trapping exit do not die when an error occurs in an Actor they are linked to. Instead the exit message is sent to their regular mailbox in the form [:exit, actor, reason]. This allows certain Actors to supervise sets of others and restart them in the event of an error. Setting the trap flag may be interrupted by pending exit notifications.

unlink(actor)

Unlink the current Actor from another one

Public Instance methods

<<(message)

Alias for send

notify_exited(actor, reason)

Notify this actor that one of the Actors it‘s linked to has exited; this is not intended to be used directly except by actor implementations. Most users will want to use Actor.send_exit instead.

notify_link(actor)

Notify this actor that it‘s now linked to the given one; this is not intended to be used directly except by actor implementations. Most users will want to use Actor.link instead.

notify_unlink(actor)

Notify this actor that it‘s now unlinked from the given one; this is not intended to be used directly except by actor implementations. Most users will want to use Actor.unlink instead.

send(message)