class Dynflow::Executors::Parallel::Pool::JobStorage

Public Class Methods

new() click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 6
def initialize
  @jobs = []
end

Public Instance Methods

add(work) click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 10
def add(work)
  @jobs << work
end
empty?() click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 22
def empty?
  @jobs.empty?
end
pop() click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 14
def pop
  @jobs.shift
end
queue_size() click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 18
def queue_size
  execution_status.values.reduce(0, :+)
end