code: public void deletePath(final Path path, final boolean recursive) {
      this.futures.add(new NamedFuture(this.executor.submit(new Callable<Void>() {
        @Override
        public Void call() throws Exception {
          Lock lock = ParallelRunner.this.locks.get(path.toString());
          lock.lock();
          try {
            HadoopUtils.deletePath(ParallelRunner.this.fs, path, recursive);
            return null;
          } finally {
            lock.unlock();
          }
        }
      }), "Delete path " + path));
    }
docs: Delete a {@link Path}.
  
  <p>
  This method submits a task to delete a {@link Path} and returns immediately
  after the task is submitted.
  </p>
  
  @param path path to be deleted.