lib/capistrano/asg/rolling/parallel.rb in capistrano-asg-rolling-0.4.1 vs lib/capistrano/asg/rolling/parallel.rb in capistrano-asg-rolling-0.5.0

- old
+ new

@@ -9,13 +9,12 @@ module Parallel module_function def run(work) result = Concurrent::Array.new - threads = [] - work.each do |w| - threads << Thread.new do + threads = work.map do |w| + Thread.new do result << yield(w) end end threads.each(&:join)