code: @Override
  	public void run() {
  		long currentTime = timeProvider.currentTime();
  		for(Job job : scheduler.jobStatus()) {
  			cleanUpLongJobIfItHasFinishedExecuting(currentTime, job);
  			detectLongRunningJob(currentTime, job);
  		}
  	}
docs: Run the too long jobs detection on the {@link Scheduler}.
  This method is *not* thread safe.