public Future<?> drainContinuously(){
  return drainer.submit(new ContinuousDrain());
}

public Future < ? > drainContinuously ( ) { return drainer . submit ( new ContinuousDrain ( ) ) ; }
drain the queue in a non - blocking way , without ever timing out , until the draining thread is interrupted or the task is cancelled .
