RejectedExecutionHandler是处理线程池拒绝任务的接口，包含rejectedExecution方法；JDK提供四种策略：AbortPolicy抛异常、CallerRunsPolicy由调用线程执行、DiscardPolicy静默丢弃、DiscardOldestPolicy丢弃最老任务；可通过构造函数或setRejectedExecutionHandler设置；可自定义实现，如记录日志或持久化任务；选择策略需根据数据完整性、系统稳定性及业务需求综合考虑。
当Java线程池中的任务队列已满且线程数量达到最大限制时，新提交的任务无法被接受，此时会触发拒绝策略。这个策略由RejectedExecutionHandler接口定义，用于处理那些不能被执行的task。
RejectedExecutionHandler 是什么？
RejectedExecutionHandler 是一个接口，包含一个方法：void rejectedExecution(Runnable r, ThreadPoolExecutor executor)，当任务被拒绝时，该方法会被调用。开发者可以自定义拒绝逻辑，也可以使用JDK提供的几种常见实现。
四种内置拒绝策略
JDK在ThreadPoolExecutor中提供了四种标准的拒绝策略：
AbortPolicy（默认）：抛出RejectedExecutionException异常，提示任务被拒绝。 CallerRunsPolicy：由提交任务的线程（即调用者线程）直接执行该任务。这可以减缓新任务的提交速度，适用于希望平滑降级的场景。 DiscardPolicy：静默丢弃无法处理的任务，不抛异常也不执行。 DiscardOldestPolicy：丢弃队列中最老的一个任务（即等待时间最长的），然后尝试重新提交当前任务。注意：如果线程池已关闭，仍会丢弃任务。
如何设置拒绝策略？
创建线程池时可以通过构造函数或setRejectedExecutionHandler()方法指定策略：
豆包AI编程
豆包推出的AI编程助手
483 查看详情
立即学习“Java免费学习笔记（深入）”；
// 使用自定义或内置策略ThreadPoolExecutor executor = new ThreadPoolExecutor( 2, 4, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue(2), new ThreadPoolExecutor.AbortPolicy() // 可替换为其他策略);// 或动态设置executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
自定义拒绝策略
如果内置策略无法满足业务需求，可以实现自己的处理方式：
public class CustomRejectedHandler implements RejectedExecutionHandler { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { System.err.println("任务被拒绝: " + r.toString()); // 可记录日志、写入磁盘队列、发送告警等 }}
将自定义类传入线程池即可生效。例如在高可用系统中，可将拒绝任务持久化到本地文件或消息队列，后续恢复时重试。
选择合适的策略建议
对数据完整性要求高的场景，避免使用DiscardPolicy或DiscardOldestPolicy，考虑记录日志或落盘。 服务间调用且能容忍延迟时，CallerRunsPolicy有助于反压控制，防止雪崩。 默认AbortPolicy适合快速失败设计，便于及时发现问题。基本上就这些。合理配置拒绝策略是保障系统稳定性的重要一环，尤其在高并发环境下不可忽视。
以上就是Java中线程池RejectedExecutionHandler处理的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/591203.html
微信扫一扫 
支付宝扫一扫 
