class Bundler::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 { @request_queue.enq POISON }
  @threads.each { |thread| thread.join }
end