import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;

public class AbstractDelegatingExecutorService<S extends ExecutorService> extends AbstractExecutorService {
    protected final S delegate;

    public AbstractDelegatingExecutorService(S delegate) {
        this.delegate = delegate;
    }

    @Override
    public void shutdown() {
        delegate.shutdown();

import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public abstract class AbstractManagedExecutor<S extends ExecutorService> extends AbstractDelegatingExecutorService<S> implements ManagedExecutor {
    @SuppressWarnings("ThreadLocalUsage")
    private final ThreadLocal<Object> executing = new ThreadLocal<Object>();
    private final ExecutorPolicy executorPolicy;