AbstractExecutorService 不可继承，应使用装饰器模式包装 ExecutorService 或继承 ThreadPoolExecutor；直接实现 ExecutorService 接口仅适用于高度定制场景。
注意：AbstractExecutorService 是一个抽象类，但它不是设计用来被用户直接继承扩展的。Java 官方文档明确说明：该类仅用于 JDK 内部实现（如 ThreadPoolExecutor），其构造方法是包私有的（package-private），且不保证 API 稳定性。试图继承它会导致编译失败或运行时风险。
如果你的目标是实现自定义线程池行为（比如记录任务执行时间、拦截任务、添加监控、统一异常处理等），正确且推荐的方式是：
✅ 推荐方式：组合 + 装饰器模式（Wrapper）
基于 ExecutorService 接口，包装现有线程池（如 ThreadPoolExecutor），在 submit/execute/invokeXXX 等方法中增强逻辑。
public class LoggingExecutorService implements ExecutorService {
private final ExecutorService delegate;
public LoggingExecutorService(ExecutorService delegate) {
this.delegate = delegate;
}
@Override
public void execute(Runnable command) {
long start = System.nanoTime();
delegate.execute(() -> {
try {
command.run();
} finally {
long cost = System.nanoTime() - start;
System.out.printf("Task %s executed in %.2f ms%n",
command.getClass().getSimpleName(),
cost / 1_000_000.0);
}
});
}
// 其他方法（submit, invokeAll, shutdown 等）均委托给 delegate
// 可按需增强，例如 submit(Callable) 中捕获异常、打日志、埋点等
@Override public <T> Future<T> submit(Callable<T> task) { return delegate.submit(task); }
@Override public <T> Future<T> submit(Runnable task, T result) { return delegate.submit(task, result); }
@Override public Future<?> submit(Runnable task) { return delegate.submit(task); }
@Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException { return delegate.invokeAll(tasks); }
// ... 实现剩余接口方法（可借助 Executors.privilegedThreadFactory() 或 Apache Commons Lang 的 DelegatingExecutorService 简化）
}使用示例：
立即学习“Java免费学习笔记（深入）”；
ExecutorService customPool = new LoggingExecutorService(
Executors.newFixedThreadPool(4)
);
customPool.submit(() -> {
Thread.sleep(100);
System.out.println("done");
});✅ 替代方案：继承 ThreadPoolExecutor（安全 & 强大）
ThreadPoolExecutor 是公开、稳定、可继承的类，提供了多个 protected 钩子方法，专为定制设计：
-
beforeExecute(Thread t, Runnable r) -
afterExecute(Runnable r, Throwable t) -
terminated()
public class TracingThreadPoolExecutor extends ThreadPoolExecutor {
public TracingThreadPoolExecutor(int corePoolSize, int maxPoolSize,
long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue) {
super(corePoolSize, maxPoolSize, keepAliveTime, unit, workQueue);
}
@Override
protected void beforeExecute(Thread t, Runnable r) {
System.out.println("[" + t.getName() + "] starting " + r);
super.beforeExecute(t, r);
}
@Override
protected void afterExecute(Runnable r, Throwable t) {
if (t != null) {
System.err.println("Task " + r + " threw exception: " + t);
}
System.out.println("[" + Thread.currentThread().getName() + "] finished " + r);
super.afterExecute(r, t);
}
}❌ 为什么不要继承 AbstractExecutorService？
- 它的构造函数是
AbstractExecutorService()（包级私有），外部类无法调用； - 没有提供
execute()的默认实现，子类必须重写，但内部状态（如newTaskFor工厂逻辑）未暴露，难以正确复现； - JDK 从未承诺该类的二进制兼容性，JDK 版本升级可能破坏继承逻辑；
- 所有标准线程池（
ForkJoinPool,ThreadPoolExecutor,ScheduledThreadPoolExecutor）都不继承它，而是直接实现ExecutorService接口或继承更具体的类。
? 小结：该怎么做？
- 想加日志、监控、熔断、上下文传递？→ 用装饰器包装
ExecutorService - 想控制线程创建、任务前后钩子、拒绝策略扩展？→ 继承
ThreadPoolExecutor并重写钩子方法 - 想彻底重写调度逻辑（如协程式、优先级队列、分布式任务分发）？→ 直接实现
ExecutorService接口（但需自行管理线程、生命周期、Future构造等，复杂度高）
不复杂但容易忽略：面向接口编程 + 组合优于继承，才是 Java 并发扩展的正道。
