class Dynflow::Executors::Parallel::Pool::JobStorage
Public Class Methods
new()
click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 7 def initialize @jobs = [] end
Public Instance Methods
add(work)
click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 11 def add(work) @jobs << work end
empty?()
click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 23 def empty? @jobs.empty? end
pop()
click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 15 def pop @jobs.shift end
queue_size()
click to toggle source
# File lib/dynflow/executors/parallel/pool.rb, line 19 def queue_size execution_status.values.reduce(0, :+) end