pmap.rb

require 'celluloid'

module Enumerable
  # Parallel map. Calculates each element in a separate thread.
  def pmap(timeout=nil, &block)
    map {|element|
      Celluloid::Future.new(element, &block)
    }.map{|result|
      begin
        result.value(timeout)
      rescue RuntimeError
      end
    }.compact
  end
end

#for example

[1,2,3,4].pmap{|x| x*x}
[1,2,3,4].pmap(5){|x| x*x} #- the same but with 5 sec limit