线程池在高并发下需处理任务拒绝和异常。当无法接收新任务时，触发拒绝策略：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，异常会被吞掉。
GAIPPT
AI PPT制作和美化神器
1215 查看详情
解决方法有以下几种：
在 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);
这样即使任务中未捕获异常，也能被统一处理。
基本上就这些。合理配置拒绝策略和异常捕获机制，能显著提升系统的健壮性和可观测性。
以上就是Java中如何处理线程池拒绝策略与异常管理的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/769202.html
微信扫一扫 
支付宝扫一扫 
