code: @Override
  	public void run() {
  		while (!this.isClosed()) {
  			this.flushTasks();
  
  			TimeSpan timeSpan = this.periodicTimeSpan;
  			long timeToWait = timeSpan != null ? timeSpan.getTotalMs() : 0;
  
  			try {
  				Thread.sleep(timeToWait);
  			} catch (InterruptedException e) { }
  		}
  	}
docs: //////////////