lib/materialize/concurrent.rb in materialize-0.2.4 vs lib/materialize/concurrent.rb in materialize-0.2.5

- old
+ new

@@ -1,13 +1,15 @@ -module Concurrent +module Materialize + module Concurrent - def concurrent(*lambdas) - threads = [] - lambdas.each do |l| - threads << Thread.new do - l.() + def concurrent(*lambdas) + threads = [] + lambdas.each do |l| + threads << Thread.new do + l.() + end end + threads.each(&:join) end - threads.each(&:join) - end + end end