class Baleen::RunnerManager
Public Class Methods
new(connection, task)
click to toggle source
# File lib/baleen/runner.rb, line 7 def initialize(connection, task) @task = task @connection = connection end
Public Instance Methods
run() { |task| ... }
click to toggle source
# File lib/baleen/runner.rb, line 12 def run results = [] prepare_task create_runners.each do |runners| runners.map{|runner| runner.future.run}.each do |actor| results << actor.value end end @task.results = results yield @task end
Private Instance Methods
create_runners()
click to toggle source
# File lib/baleen/runner.rb, line 30 def create_runners @task.target_files.map {|file| task = @task.dup task.files = file Runner.new(task, @connection) }.each_slice(@task.concurrency).map {|r| r} end
prepare_task()
click to toggle source
# File lib/baleen/runner.rb, line 26 def prepare_task @task.prepare end