Java线程池拒绝执行异常：为什么我的线程池总是会在completed tasks达到特定值时抛出RejectedExecutionException？

Java线程池拒绝执行异常：详细说明RejectedExecutionexception

Java并发编程，java.util.concurrent.RejectedExecutionException 异常是线程池处理任务能力饱和时常见的错误报告。本文将通过实际案例深入分析异常的原因，并提出相应的解决方案。

案例描述:用户使用线程池，其核心线程数和最大线程数设置为 processNum * 10.阻塞队列为容量1万的LinkedBlockingQueue，拒绝策略为AbortPolicy。运行一段时间后，线程池状态如下:pool size = 160, active threads = 160, queued tasks = 10000, completed tasks = 588179 抛出Rejectedexecutionexception。重新启动服务器后，当completed tasks 当达到相同数量时，异常再次出现。

根本原因：异常不是线程池参数配置错误，而是AbortPolicy 拒绝策略。当所有的线程都很忙，队列已经满了，新的任务就不能接受，AbortPolicy 异常直接抛出。 completed tasks 当异常发生时，数值只是一种状态，而不是问题的根源。 真正的核心问题是，任务提交速度继续超过线程池的处理速度。

立即学习“Java免费学习笔记(深入)；

解决方案：

1. 性能分析： 首先，必须仔细分析应用程序的任务提交速率和线程池的处理能力。如果提交速率过高，需要优化代码，减少不必要的任务提交。

2. 调整线程池参数： 可以考虑增加corePolsize 和 maximumPoolSize，提高线程池的并发处理能力。但要小心，过多的线程可能会加剧资源竞争。

3. 更换拒绝策略： AbortPolicy 策略过于直接，建议用更温和的策略代替:

   • CallerRunsPolicy: 直接执行提交任务的线程，降低提交速率。
   • DiscardPolicy: 直接丢弃新任务，适用于任务丢失容忍度较高的场景。
   • DiscardOldestPolicy: 在试图提交新任务之前，丢弃队列中最旧的任务。

根据实际业务场景和对任务丢失的容忍度，需要权衡选择合适的拒绝策略。

总结:解决Rejectedexecutionexception 关键是要平衡提交任务的速度和线程池的处理能力，并选择合适的拒绝策略。 通过性能分析、参数调整和策略优化，可以有效避免这种异常。

以上是Java线程池拒绝执行异常：为什么我的线程池总是在completed上 当tasks达到特定值时，抛出Rejectedexecutionexception？详情请关注图灵教育的其他相关文章！