Module: Enumerable

Defined in:
lib/parallel_each.rb

Instance Method Summary collapse

Instance Method Details

#p_each(max_tasks = 20, &block) ⇒ Object 



5
6
7
8
9
10
11
12
13
 
# File 'lib/parallel_each.rb', line 5

def p_each(max_tasks=20, &block)
  runner = BoundedAsyncTaskRunner.new(max_tasks)

  each do |item|
    runner.do(item, &block)
  end

  runner.wait_for_all_to_finish
end