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