Module: Enumerable

Defined in:

lib/parallelpipes.rb

Instance Method Summary

• #parallel_map(*args, &block) ⇒ Object

Instance Method Details

#parallel_map(*args, &block) ⇒ Object

# File 'lib/parallelpipes.rb', line 2376

def parallel_map(*args, &block)
  ncpus = number_of_processors_for_parallel_map
  if args[-1].class == Hash
    options = args.pop
    ncpus = options[:n_procs] if options[:n_procs]
  end
    
  ppipe = PPipe.new(ncpus, false)
  ppipe.fork(ncpus-1) 
  i = -1
  each(*args) do |*yargs|
#         $stderr.puts i, ppipe.mpn
    i+=1
    next unless i%ncpus == ppipe.mpn 
    value = block.call(*yargs)
#         $stderr.puts value
    ppipe.i_send(i, Marshal.dump(value), tp: 0)
    
  end
  (ppipe.die; exit) unless ppipe.is_root
  ppipe.waitall
  i = 0
  map(*args) do |*yargs|
    value = Marshal.load(ppipe.w_recv(i))
    i+=1
    value
  end
end