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)