Class: Dynflow::Executors::Parallel::Pool::JobStorage

Inherits:

Object

• Object
• Dynflow::Executors::Parallel::Pool::JobStorage

Defined in:

lib/dynflow/executors/parallel/pool.rb

Instance Method Summary

• #add(work) ⇒ Object
• #empty? ⇒ Boolean
• #initialize ⇒ JobStorage constructor

  A new instance of JobStorage.

• #pop ⇒ Object
• #queue_size(execution_plan_id = nil) ⇒ Object

Constructor Details

#initialize ⇒ JobStorage

Returns a new instance of JobStorage.

# File 'lib/dynflow/executors/parallel/pool.rb', line 7

def initialize
  @jobs = []
end

Instance Method Details

#add(work) ⇒ Object

# File 'lib/dynflow/executors/parallel/pool.rb', line 11

def add(work)
  @jobs << work
end

#empty? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/dynflow/executors/parallel/pool.rb', line 23

def empty?
  @jobs.empty?
end

#pop ⇒ Object

# File 'lib/dynflow/executors/parallel/pool.rb', line 15

def pop
  @jobs.shift
end

#queue_size(execution_plan_id = nil) ⇒ Object

# File 'lib/dynflow/executors/parallel/pool.rb', line 19

def queue_size
  execution_status.values.reduce(0, :+)
end