Module: Procrastinator::Scheduler::SerialWorking

Included in:
WorkProxy
Defined in:
lib/procrastinator/scheduler.rb

Overview

Serial work style

See Also:

Instance Method Summary collapse

Instance Method Details

#serially(steps: 1) ⇒ Object

Work off the given number of tasks for each queue and return

Parameters:

  • steps (integer) (defaults to: 1) —

    The number of tasks to complete.



117
118
119
120
121
 
# File 'lib/procrastinator/scheduler.rb', line 117

def serially(steps: 1)
   steps.times do
      workers.each(&:work_one)
   end
end