Module: Enumerable

Defined in:
lib/parallel_enumerable.rb

Overview

Monkey patching Enumerable to make it easy to do any .each in parallel Example - Will run puppet agent -t on each agent in parallel: agents.each_in_parallel { |agent|

on agent, 'puppet agent -t'

}

Instance Method Summary collapse

Instance Method Details

#each_in_parallel(method_sym = nil, &block) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/parallel_enumerable.rb', line 7

def each_in_parallel(method_sym=nil, &block)
  if Process.respond_to?(:fork) && count > 1
    method_sym ||= "#{caller_locations[0]}"
    each do |item|
      out = InParallelExecutor._execute_in_parallel(method_sym) {block.call(item)}
      puts "'each_in_parallel' forked process for '#{method_sym}' - PID = '#{out[:pid]}'\n"
    end
    # return the array of values, no need to look up from the map.
    return InParallel.wait_for_processes
  end
  puts 'Warning: Fork is not supported on this OS, executing block normally' unless Process.respond_to? :fork
  block.call
  each(&block)
end