code: @SuppressWarnings({ "rawtypes", "unchecked" })
      @Override
      public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
          Entry<Collection<? extends Callable<T>>, TaskLifeCycleCallback[]> entry = createCallbacks(tasks);
          tasks = entry.getKey();
          TaskLifeCycleCallback[] callbacks = entry.getValue();
  
          // Policy executor can optimize the last task in the list to run on the current thread if we submit under the same executor,
          PolicyExecutor executor = callbacks.length > 0 ? callbacks[callbacks.length - 1].policyExecutor : policyExecutor;
          return (List) executor.invokeAll(tasks, callbacks);
      }
docs: {@inheritDoc}