Actor

# File lib/girl_friday/actor.rb, line 92
def check_for_interrupt
  current._check_for_interrupt
  self
end

# File lib/girl_friday/actor.rb, line 57
def current
  Thread.current[:__current_actor__] ||= private_new
end

# File lib/girl_friday/actor.rb, line 118
def link(actor)
  current = self.current
  current.notify_link actor
  actor.notify_link current
  self
end

# File lib/girl_friday/actor.rb, line 152
def lookup(name)
  raise ArgumentError, "name must be a symbol" unless Symbol === name
  @@registered_lock.pop
  begin
    @@registered[name]
  ensure
    @@registered_lock << nil
  end
end

# File lib/girl_friday/actor.rb, line 193
def initialize
  @lock = Queue.new

  @filter = nil
  @ready = Queue.new
  @action = nil
  @message = nil

  @mailbox = []
  @interrupts = []
  @links = []
  @alive = true
  @exit_reason = nil
  @trap_exit = false
  @thread = Thread.current

  @lock << nil

  if block_given?
    watchdog { yield self }
  else
    Thread.new { watchdog { @thread.join } }
  end
end

# File lib/girl_friday/actor.rb, line 100
def receive #:yields: filter
  filter = Filter.new
  if block_given?
    yield filter
  else
    filter.when(ANY) { |m| m }
  end
  current._receive(filter)
end

# File lib/girl_friday/actor.rb, line 164
def register(name, actor)
  raise ArgumentError, "name must be a symbol" unless Symbol === name
  unless actor.nil? or actor.is_a?(Actor)
    raise ArgumentError, "only actors may be registered"
  end

  @@registered_lock.pop
  begin
    if actor.nil?
      @@registered.delete(name)
    else
      @@registered[name] = actor
    end
  ensure
    @@registered_lock << nil
  end
end

# File lib/girl_friday/actor.rb, line 112
def send_exit(recipient, reason)
  recipient.notify_exited(current, reason)
  self
end

# File lib/girl_friday/actor.rb, line 62
def spawn(*args, &block)
  raise ArgumentError, "no block given" unless block
  spawned = Queue.new
  Thread.new do
    private_new do |actor|
      Thread.current[:__current_actor__] = actor
      spawned << actor
      block.call(*args)
    end
  end
  spawned.pop
end

# File lib/girl_friday/actor.rb, line 77
def spawn_link(*args, &block)
  current = self.current
  link_complete = Queue.new
  spawn do
    begin
      Actor.link(current)
    ensure
      link_complete << Actor.current
    end
    block.call(*args)
  end
  link_complete.pop
end

# File lib/girl_friday/actor.rb, line 146
def trap_exit
  current._trap_exit
end

# File lib/girl_friday/actor.rb, line 140
def trap_exit=(value)
  current._trap_exit = value
  self
end

# File lib/girl_friday/actor.rb, line 126
def unlink(actor)
  current = self.current
  current.notify_unlink actor
  actor.notify_unlink current
  self
end

# File lib/girl_friday/actor.rb, line 352
def notify_exited(actor, reason)
  exit_message = nil
  @lock.pop
  begin
    return self unless @alive
    @links.delete(actor)
    if @trap_exit
      exit_message = DeadActorError.new(actor, reason)
    elsif reason
      @interrupts << DeadActorError.new(actor, reason)
      if @filter
        @filter = nil
        @ready << nil
      end
    end
  ensure
    @lock << nil
  end
  send exit_message if exit_message
  self
end

# File lib/girl_friday/actor.rb, line 318
def notify_link(actor)
  @lock.pop
  alive = nil
  exit_reason = nil
  begin
    alive = @alive
    exit_reason = @exit_reason
    @links << actor if alive and not @links.include? actor
  ensure
    @lock << nil
  end
  actor.notify_exited(self, exit_reason) unless alive
  self
end

# File lib/girl_friday/actor.rb, line 337
def notify_unlink(actor)
  @lock.pop
  begin
    return self unless @alive
    @links.delete(actor)
  ensure
    @lock << nil
  end
  self
end

# File lib/girl_friday/actor.rb, line 218
def send(message)
  @lock.pop
  begin
    return self unless @alive
    if @filter
      @action = @filter.action_for(message)
      if @action
        @filter = nil
        @message = message
        @ready << nil
      else
        @mailbox << message
      end
    else
      @mailbox << message
    end
  ensure
    @lock << nil
  end
  self
end