class ParallelEach

def each
  threads = N.times.map {
    Thread.new do
      Thread.current.abort_on_exception = true
      while job = @queue.pop
        yield job
      end
    end
  }
  threads.map(&:join)
end

def grep pattern # :nodoc:
  self.class.new super
end

def initialize list
  @queue = Queue.new # *sigh*... the Queue api sucks sooo much...
  list.each { |i| @queue << i }
  N.times { @queue << nil }
end