parallel_each

gistfile1.rb

module Enumerable
  DEFAULT_PARALLEL = 8

  def parallel_each(num = DEFAULT_PARALLEL)
    threads = []
    queue = Queue.new

    num.times do
      threads << Thread.new do
        while (a = queue.pop) != nil
          yield(a)
        end
      end
    end

    self.each {|a| queue << a }
    self.size.times { queue << nil }
    threads.each {|t| t.join }
  end
end