presto-main/src/main/java/io/prestosql/dispatcher/DecoratingListeningExecutorService.java/DecoratingListeningExecutorService/invokeAll
class DecoratingListeningExecutorService:    @Override
    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
            throws InterruptedException
    {
        return delegate.invokeAll(tasks.stream()
                .map(decorator::decorate)
                .collect(toImmutableList()));
    }