code: public void start() throws Exception
      {
          Preconditions.checkState(state.compareAndSet(State.LATENT, State.STARTED), "Cannot be started more than once");
  
          task = executor.scheduleWithFixedDelay
          (
              new Runnable()
              {
                  @Override
                  public void run()
                  {
                      doWork();
                  }
              },
              reapingThresholdMs,
              reapingThresholdMs,
              TimeUnit.MILLISECONDS
          );
          if (leaderLatch != null)
          {
              leaderLatch.start();
          }
          reaper.start();
      }
docs: The reaper must be started
  
  @throws Exception errors