Class: Concurrent::Actor::Core

Inherits:

Synchronization::LockableObject

• Object
• Synchronization::LockableObject
• Concurrent::Actor::Core

show all

Includes:

TypeCheck

Defined in:

lib/concurrent/actor/core.rb

Overview

Instance Attribute Summary (collapse)

• - (Context) actor_class readonly

  A subclass of AbstractContext representing Actor's behaviour.

• - (undocumented) behaviour_definition readonly
• - (undocumented) context readonly
• - (undocumented) context_class readonly
• - (Executor) executor readonly

  Executor which is used to process messages.

• - (String) name readonly

  The name of actor instance, it should be uniq (not enforced).

• - (String) path readonly

  Path of this actor.

• - (Reference) reference readonly

  Reference to this actor which can be safely passed around.

Instance Method Summary (collapse)

• - (undocumented) add_child(child) private
• - (undocumented) allocate_context private
• - (Behaviour::Abstract, nil) behaviour(behaviour_class)

  Based on behaviour_class.

• - (Behaviour::Abstract) behaviour!(behaviour_class)

  Based on behaviour_class.

• - (undocumented) broadcast(public, event)
• - (undocumented) build_context private
• - (undocumented) Child!(value, *types) included from TypeCheck
• - (Boolean) Child?(value, *types) included from TypeCheck
• - (Array<Reference>) children

  Of children actors.

• - (undocumented) dead_letter_routing
• - (undocumented) guard!

  ensures that we are inside of the executor.

• - (Core) initialize(opts = {}, &block) constructor

  A new instance of Core.

• - (undocumented) log(level, message = nil, &block)
• - (undocumented) Match!(value, *types) included from TypeCheck
• - (Boolean) Match?(value, *types) included from TypeCheck
• - (undocumented) on_envelope(envelope)

  is executed by Reference scheduling processing of new messages can be called from other alternative Reference implementations.

• - (Reference, nil) parent

  A parent Actor.

• - (undocumented) process_envelope(envelope) private
• - (undocumented) remove_child(child) private
• - (undocumented) schedule_execution

  Schedules blocks to be executed on executor sequentially, sets Actress.current.

• - (undocumented) Type!(value, *types) included from TypeCheck
• - (Boolean) Type?(value, *types) included from TypeCheck

50
51
52
53

# File 'lib/concurrent/actor/core.rb', line 50

def initialize(opts = {}, &block)
  super(&nil)
  synchronize { ns_initialize(opts, &block) }
end

35

# File 'lib/concurrent/actor/core.rb', line 35

attr_reader :reference, :name, :path, :executor, :context_class, :context, :behaviour_definition

35
36
37

# File 'lib/concurrent/actor/core.rb', line 35

def behaviour_definition
  @behaviour_definition
end

35
36
37

# File 'lib/concurrent/actor/core.rb', line 35

def context
  @context
end

35
36
37

# File 'lib/concurrent/actor/core.rb', line 35

def context_class
  @context_class
end

35

# File 'lib/concurrent/actor/core.rb', line 35

attr_reader :reference, :name, :path, :executor, :context_class, :context, :behaviour_definition

35

# File 'lib/concurrent/actor/core.rb', line 35

attr_reader :reference, :name, :path, :executor, :context_class, :context, :behaviour_definition

35

# File 'lib/concurrent/actor/core.rb', line 35

attr_reader :reference, :name, :path, :executor, :context_class, :context, :behaviour_definition

35
36
37

# File 'lib/concurrent/actor/core.rb', line 35

def reference
  @reference
end

74
75
76
77
78
79

# File 'lib/concurrent/actor/core.rb', line 74

def add_child(child)
  guard!
  Type! child, Reference
  @children.add child
  nil
end

149
150
151

# File 'lib/concurrent/actor/core.rb', line 149

def allocate_context
  @context = @context_class.allocate
end

137
138
139

# File 'lib/concurrent/actor/core.rb', line 137

def behaviour(behaviour_class)
  @behaviours[behaviour_class]
end

144
145
146

# File 'lib/concurrent/actor/core.rb', line 144

def behaviour!(behaviour_class)
  @behaviours.fetch behaviour_class
end

130
131
132
133

# File 'lib/concurrent/actor/core.rb', line 130

def broadcast(public, event)
  log(DEBUG) { "event: #{event.inspect} (#{public ? 'public' : 'private'})" }
  @first_behaviour.on_event(public, event)
end

154
155
156
157

# File 'lib/concurrent/actor/core.rb', line 154

def build_context
  @context.send :initialize_core, self
  @context.send :initialize, *@args, &@block
end

68
69
70
71

# File 'lib/concurrent/actor/core.rb', line 68

def children
  guard!
  @children.to_a
end

63
64
65

# File 'lib/concurrent/actor/core.rb', line 63

def dead_letter_routing
  @context.dead_letter_routing
end

101
102
103
104
105

# File 'lib/concurrent/actor/core.rb', line 101

def guard!
  unless Actor.current == reference
    raise "can be called only inside actor #{reference} but was #{Actor.current}"
  end
end

107
108
109

# File 'lib/concurrent/actor/core.rb', line 107

def log(level, message = nil, &block)
  super level, @path, message, &block
end

92
93
94
95
96
97
98

# File 'lib/concurrent/actor/core.rb', line 92

def on_envelope(envelope)
  schedule_execution do
    log(DEBUG) { "was #{envelope.future ? 'asked' : 'told'} #{envelope.message.inspect} by #{envelope.sender}" }
    process_envelope envelope
  end
  nil
end

58
59
60

# File 'lib/concurrent/actor/core.rb', line 58

def parent
  @parent_core && @parent_core.reference
end

160
161
162

# File 'lib/concurrent/actor/core.rb', line 160

def process_envelope(envelope)
  @first_behaviour.on_envelope envelope
end

82
83
84
85
86
87

# File 'lib/concurrent/actor/core.rb', line 82

def remove_child(child)
  guard!
  Type! child, Reference
  @children.delete child
  nil
end

113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128

# File 'lib/concurrent/actor/core.rb', line 113

def schedule_execution
  @serialized_execution.post(@executor) do
    synchronize do
      begin
        Thread.current[:__current_actor__] = reference
        yield
      rescue => e
        log FATAL, e
      ensure
        Thread.current[:__current_actor__] = nil
      end
    end
  end

  nil
end