subprojects/parseq/src/main/java/com/linkedin/parseq/internal/ExecutionMonitor.java
private void monitor() {
    _lastMonitoringStep = _clock.nanoTime();
    _nextAllowedLogging = _lastMonitoringStep;
    while(!_stopped) {
      try {
        _clock.sleepNano(_checkIntervalNano);
      } catch (InterruptedException e) {
        break;
      }
      monitorStep();
    }
  }
private void monitor() {
    _lastMonitoringStep = _clock.nanoTime();
    _nextAllowedLogging = _lastMonitoringStep;
    while(!_stopped) {
      try {
        _clock.sleepNano(_checkIntervalNano);
      } catch (InterruptedException e) {
        break;
      }
      monitorStep();
    }
  }
Main loop of monitoring thread.