}

    @Override
    public RejectedExecutionHandler getRejectedExecutionHandler() {
        return delegate.getRejectedExecutionHandler();
    }

    @Override
    public void setCorePoolSize(int corePoolSize) {
        delegate.setCorePoolSize(corePoolSize);
    }

    @Override
    public int getCorePoolSize() {
        return delegate.getCorePoolSize();
    }

    @Override
    public boolean prestartCoreThread() {

    ThreadFactory getThreadFactory();

    void setRejectedExecutionHandler(@Nonnull RejectedExecutionHandler handler);

    RejectedExecutionHandler getRejectedExecutionHandler();

    void setCorePoolSize(int corePoolSize);

    int getCorePoolSize();

    boolean prestartCoreThread();

    int prestartAllCoreThreads();

    boolean allowsCoreThreadTimeOut();

                        throws InterruptedException {
                    setCorePoolSize(parallelism + parked.incrementAndGet());
                    try {
                        return super.invokeAll(tasks);
                    } finally {
                        setCorePoolSize(parallelism + parked.decrementAndGet());
                    }
                }
            };
        }