Class: Dynflow::Actor

Inherits:

Concurrent::Actor::Context

• Object
• Concurrent::Actor::Context
• Dynflow::Actor

Includes:

Algebrick::Matching, LogWithFullBacktrace, MethodicActor

Defined in:

lib/dynflow/actor.rb

Overview

Common parent for all the Dynflow actors defining some defaults that we preffer here.

Direct Known Subclasses

Dynflow::Actors::ExecutionPlanCleaner::Core, Clock, Connectors::Database::Core, Connectors::Direct::Core, DelayedExecutors::AbstractCore, Dispatcher::Abstract, Executors::Abstract::Core, Executors::Parallel::Pool, Executors::Parallel::Worker, ThrottleLimiter::Core

Defined Under Namespace

Modules: LogWithFullBacktrace Classes: BacktraceCollector, PoliteTermination, SetResultsWithOriginLogging

Instance Method Summary

• #behaviour_definition ⇒ Object
• #finish_termination ⇒ Object
• #start_termination(future) ⇒ Object
• #terminating? ⇒ Boolean

Methods included from MethodicActor

#on_message

Methods included from LogWithFullBacktrace

#log

Instance Method Details

#behaviour_definition ⇒ Object

# File 'lib/dynflow/actor.rb', line 142

def behaviour_definition
  [*Concurrent::Actor::Behaviour.base(:just_log),
   Concurrent::Actor::Behaviour::Buffer,
   [SetResultsWithOriginLogging, :just_log],
   Concurrent::Actor::Behaviour::Awaits,
   PoliteTermination,
   Concurrent::Actor::Behaviour::ExecutesContext,
   Concurrent::Actor::Behaviour::ErrorsOnUnknownMessage]
end

#finish_termination ⇒ Object

# File 'lib/dynflow/actor.rb', line 133

def finish_termination
  @terminated.fulfill(true)
  reference.tell(:terminate!)
end

#start_termination(future) ⇒ Object

# File 'lib/dynflow/actor.rb', line 129

def start_termination(future)
  @terminated = future
end

#terminating? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/dynflow/actor.rb', line 138

def terminating?
  !!@terminated
end