code: public void start()
      {
          Preconditions.checkState(state.compareAndSet(State.LATENT, State.STARTED), "Cannot be started more than once");
  
          service.submit
              (
                  new Callable<Object>()
                  {
                      @Override
                      public Object call() throws Exception
                      {
                          processEvents();
                          return null;
                      }
                  }
              );
      }
docs: Start the manager