class Bundler::ParallelWorkers::ThreadWorker

def prepare_workers(size, func)
  @threads = size.times.map do |i|
    Thread.start do
      loop do
        obj = @request_queue.deq
        break if obj.equal? POISON
        begin
          @response_queue.enq func.call(obj, i)
        rescue Exception => e
          @response_queue.enq(WrappedException.new(e))
        end
      end
    end
  end
end