class Concurrent::Supervisor

def one_for_all
  restart = false
  restart = @workers.each do |context|
    if context.needs_restart?
      raise MaxRestartFrequencyError if exceeded_max_restart_frequency?
      break(true)
    end
  end
  if restart
    @workers.each do |context|
      terminate_worker(context)
    end
    @workers.each{|context| run_worker(context)}
  end
end