code: protected <T> RunnableFuture<T> newTaskFor(Runnable runnable, T value) {
          return new ClusteredFutureTask<T>(runnable, value);
      }
docs: ---- ExecutorService implementation ----------------------------------