class ActiveSupport::Testing::Parallelization

def shutdown

def shutdown
  @queue_server.shutdown
  @worker_pool.each { |pid| Process.waitpid pid }
end