Class: Baleen::RunnerManager
- Inherits:
-
Object
- Object
- Baleen::RunnerManager
- Defined in:
- lib/baleen/runner.rb
Instance Method Summary collapse
-
#initialize(connection, task) ⇒ RunnerManager
constructor
A new instance of RunnerManager.
- #run {|@task| ... } ⇒ Object
Constructor Details
#initialize(connection, task) ⇒ RunnerManager
Returns a new instance of RunnerManager.
7 8 9 10 |
# File 'lib/baleen/runner.rb', line 7 def initialize(connection, task) @task = task @connection = connection end |
Instance Method Details
#run {|@task| ... } ⇒ Object
12 13 14 15 16 17 18 19 20 21 22 |
# 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 |