class ActiveSupport::Testing::Parallelization::Server

def shutdown
  # Wait for initial queue to drain
  while @queue.length != 0
    sleep 0.1
  end
  @queue.close
  # Wait until all workers have finished
  while active_workers?
    sleep 0.1
  end
  @in_flight.values.each do |(klass, name, reporter)|
    result = Minitest::Result.from(klass.new(name))
    error = RuntimeError.new("result not reported")
    error.set_backtrace([""])
    result.failures << Minitest::UnexpectedError.new(error)
    reporter.synchronize do
      reporter.record(result)
    end
  end
end