Implementation of an asynchronous execution of blocks on items in a collection, applied to enumerable using monkey patching

collection_utils.rb

module DebDeploy
  module AsynchronousCollection
    def each(&block)
      threads = []
      super do |item|
        threads << Thread.new { yield item }
      end
      threads.each(&:join)
    end

    def map(&block)
      super do |item|
        Thread.new { Thread.current[:output] = block[item] }
      end.map(&:join).map { |thread| thread[:output] }
    end
  end
end

Gemfile

source :rubygems

gem 'rake', '0.8.7'
gem "retroactive_module_inclusion", "~> 1.2.5"

parallel_enumerable.rb

require 'deb_deploy/util/collection_utils'

module CoreExt
	module Enumerable
		module Parallellization
			def async
				self.clone.extend DebDeploy:AsynchronousCollection
			end
		end
	end
end
Enumerable.send :retroactively_include, CoreExt::Enumerable::Parallellization

usage.rb

["aa","bb"].async.each{|x| x.chop }