Peach

peach.rb

class Peach
  private_class_method :new

  def self.enum_for(*args)
    new(*args)
  end

  def initialize(list, pool_size = 5)
    @queue = list.inject(Queue.new, :<<)
    @pool_size = pool_size
  end

  def each
    Array.new(@pool_size) do
      Thread.new do
        yield(@queue.pop, @queue) until @queue.empty?
      end
    end.each(&:join)
  end
end