class ActiveSupport::Testing::Parallelization::Server

def initialize
  @queue = Queue.new
  @active_workers = Concurrent::Map.new
  @in_flight = Concurrent::Map.new
end