class Concurrent::Supervisor

def one_for_one
  @workers.each do |context|
    if context.needs_restart?
      raise MaxRestartFrequencyError if exceeded_max_restart_frequency?
      run_worker(context)
    end
  end
end