class Bundler::ParallelWorkers::Worker

def stop_threads

so as worker threads after retrieving it, shut themselves down
Stop the worker threads by sending a poison object down the request queue
def stop_threads
  @threads.each do
    @request_queue.enq POISON
  end
  @threads.each do |thread|
    thread.join
  end
end