@Override
  protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
    FutureTask<T> task = AppScheduledExecutorService.capturePropagationAndCancellationContext(callable);
    if (shouldManifestExceptionsImmediately()) {
      return new FlippantFuture<>(task);
    }
    return task;
  }
@Override
  protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable)