解决java.util.concurrent.RejectedExecutionException

当需要自定义线程池时，

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10,
                    20,
                    0,
                    TimeUnit.SECONDS,
                    new ArrayBlockingQueue<Runnable>(10));

使用ArrayBlockingQueue作为阻塞队列，且容量设置为10，corePoolSize核心池大小设置为10，最大池大小设置为20时，那么线程池创建线程的过程如下：
1、假如需要运行1000个线程，那么当线程池中的线程小于核心池的大小时，需要创建新的线程则直接使用线程池创建；
2、当线程池中的线程数大于核心池的大小，但小于最大池的大小时，不直接创建新的线程，而是将线程放入阻塞队列中等待，当阻塞队列满了的时候线程池则会创建新的线程，但是此时线程池中的数量是小于等于最大池的大小的；
3、但是当线程池中的线程数已经达到最大池的大小时，那么则由于阻塞队列已经满了，所以就会报RejectedExecutionException异常。

解决办法：
1、可以使用无边界的阻塞队列作为线程的排队队列，比如LinkedBlockingQueue。
2、使用有界的队列时，可以根据代码调大队列的容量。
3、直接提交。工作队列的默认选项是synchronousQueue，它将任务直接提交给线程而不保持它们。在此，如果不存在可用于立即运行任务的线程，则试图把任务加入队列将失败，因此会构造一个新的线程。此策略可以避免在处理可能具有内部依赖性的请求集时出现锁。直接提交通常要求无界maximumPoolSizes以避免拒绝新提交的任务。当命令以超过队列所能处理的平均数连续到达时，此策略允许无界线程具有增加的可能性。

引用

最后

以上就是淡定鸡翅为你收集整理的解决java.util.concurrent.RejectedExecutionException的全部内容，希望文章能够帮你解决解决java.util.concurrent.RejectedExecutionException所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。