线程池在高并发下需处理任务拒绝和异常。当无法接收新任务时，触发拒绝策略：AbortPolicy抛异常、CallerRunsPolicy由调用线程执行、DiscardPolicy丢弃新任务、DiscardOldestPolicy丢弃最老任务；可自定义策略记录日志或持久化。任务异常方面，Runnable未捕获异常会导致线程终止但不传播，可通过try-catch、使用Callable结合Future.get()获取异常、重写afterExecute方法或设置ThreadFactory的UncaughtExceptionHandler来捕获和处理异常，提升系统健壮性与可观测性。
线程池在高并发场景中广泛使用，但当任务提交速度超过处理能力或线程池已关闭时，就会触发拒绝策略。同时，任务执行过程中可能抛出异常，若不妥善处理，会导致任务“静默失败”。Java 提供了多种机制来应对这些问题。
线程池拒绝策略
当线程池无法接受新任务时（如队列已满且线程数达到最大值），会触发RejectedExecutionHandler。JDK 提供了四种内置策略：
- AbortPolicy：默认策略，抛出 RejectedExecutionException 异常。
- CallerRunsPolicy：由提交任务的线程直接执行该任务，减缓提交速度。
- DiscardPolicy：静默丢弃新任务，不抛异常。
- DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试提交当前任务。
可根据业务需求选择合适策略。例如，在对数据完整性要求高的系统中，应使用 AbortPolicy 及时暴露问题；在可容忍延迟的场景下，CallerRunsPolicy 能起到“背压”作用。
也可自定义拒绝策略，记录日志、报警或持久化任务用于后续恢复：
立即学习“Java免费学习笔记（深入）”；
new RejectedExecutionHandler() {
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
System.err.println("任务被拒绝: " + r.toString());
// 可将任务写入磁盘或消息队列
}
}
线程池中的异常管理
普通 Runnable 任务中未捕获的异常会导致线程终止，但不会传播到主线程。ThreadPoolExecutor 在执行任务时会捕获 Throwable，若 Runnable 没有显式 try-catch，异常会被吞掉。
解决方法有以下几种：
- 在 Runnable 中使用 try-catch：最直接的方式，在 run 方法内处理异常。
- 使用 Callable 替代 Runnable：Callable 可抛出异常，通过 Future.get() 获取结果时会重新抛出 ExecutionException，原始异常作为其 cause。
- 重写 afterExecute 方法：继承 ThreadPoolExecutor，覆盖 afterExecute(Runnable, Throwable) 方法，在任务执行后检查异常：
protected void afterExecute(Runnable r, Throwable t) {
super.afterExecute(r, t);
if (t != null) {
System.err.println("任务执行异常: " + t);
} else if (r instanceof Future) {
try {
((Future<?>) r).get();
} catch (CancellationException ce) {
t = ce;
} catch (ExecutionException ee) {
t = ee.getCause();
} catch (InterruptedException ie) {
Thread.currentThread().interrupt();
} finally {
if (t != null) {
System.err.println("异步任务异常: " + t);
}
}
}
}
设置未捕获异常处理器
Thread 支持设置 UncaughtExceptionHandler，但线程池创建的线程通常不会自动设置。可在创建线程工厂时指定：
ThreadFactory factory = r -> {
Thread t = new Thread(r);
t.setUncaughtExceptionHandler((thread, ex) ->
System.err.println("线程异常: " + thread.getName() + ", 异常: " + ex)
);
return t;
};
ExecutorService exec = Executors.newFixedThreadPool(4, factory);
这样即使任务中未捕获异常，也能被统一处理。
基本上就这些。合理配置拒绝策略和异常捕获机制，能显著提升系统的健壮性和可观测性。
