在ThreadPoolExecutor中使用LinkedBlockingQueue(Integer.MAX_VALUE)时发生RejectedExecutionException - 腾讯云开发者社区

文章/答案/技术大牛

发布

为什么线程池不允许使用Executors去创建？

为什么线程池不允许使用Executors去创建？ Executors Executors 是一个Java中的工具类。提供工厂方法来创建不同类型的线程池。...终止并从缓存中移除那些已有 60 秒钟未被使用的线程。...17行发生异常。...而newFixedThreadPool中创建LinkedBlockingQueue时，并未指定容量。...创建线程池的正确姿势避免使用Executors创建线程主要是避免其中一些参数给的默认值，那么可以直接用ThreadPoolExecutor创建线程，并且指定具体的参数值。

4281 0

阿里面试官鬼得很，问我为什么他们阿里要禁用Executors创建线程池？

当一个任务提交时，首先会创建一个核心线程来执行任务，如果超过核心线程的数量，将会放入队列中，因为LinkedBlockingQueue是长度为Integer.MAX_VALUE的队列，可以认为是无界队列...它和SingleThreadExecutor类似，唯一的区别就是核心线程数不同，并且由于使用的是LinkedBlockingQueue，在资源有限的时候容易引起OOM异常 # 总结： FixedThreadPool...Integer.MAX_VALUE，可能会创建大量的线程，从而引起OOM异常这就是为什么禁止使用Executors去创建线程池，而是推荐自己去创建ThreadPoolExecutor的原因 # OOM...，从而使每个线程池可以根据各自的工作负载来调整阻塞队列 => 推荐使用有界队列，有界队列有助于避免资源耗尽的情况发生拒绝策略 => 默认采用的是AbortPolicy拒绝策略，直接在程序中抛出RejectedExecutionException...处理拒绝策略有以下几种比较推荐：在程序中捕获RejectedExecutionException异常，在捕获异常中对任务进行处理。

6532 0

您找到你想要的搜索结果了吗？

是的

没有找到

多线程的使用，避免ExecutorService 的创建处理

Java 中的BlockingQueue 主要有两种实现，分别是ArrayBlockingQueue 和 LinkedBlockingQueue。...也就是说，如果我们不设置LinkedBlockingQueue 的容量的话，其默认容量将会是Integer.MAX_VALUE。...而newFixedThreadPool 中创建LinkedBlockingQueue 时，并未指定容量。...(10)); 这种情况下，一旦提交的线程数超过当前可用线程数时，就会抛出java.util. concurrent.RejectedExecutionException，这是因为当前线程池使用的队列是有边界队列...但是异常（Exception）总比发生错误（Error）要好。除了自己定义ThreadPoolExecutor 外。还有其他方法。

1.2K8 1

还在用Executors创建线程池？小心内存溢出

线程池不建议使用Executors去创建，而是通过ThreadPoolExecutor的方式，这样的处理方式让写的同学更加明确线程池的运行规则，规避资源耗尽的风险。...(笔者注：阻塞队列均采用LinkedBlockingQueue) newCachedThreadPool 和 newScheduledThreadPool: 主要问题是线程数最大数是Integer.MAX_VALUE...LinkedBlockingQueue：一个由链表结构组成的有界阻塞队列，而在未指明容量时，容量默认为Integer.MAX_VALUE。...中，和LinkedBlockingQueue行为一致。...（默认）：丢弃任务并抛出RejectedExecutionException异常。

1.7K4 0

【小家java】Java中的线程池，你真的用对了吗？（教你用正确的姿势使用线程池,Executors使用中的坑）

---- 在【小家java】用 ThreadPoolExecutor/ThreadPoolTaskExecutor 线程池技术提高系统吞吐量（附带线程池参数详解和使用注意事项）这篇文章中，我们介绍过了...在文中末尾有这样一句描述：可以通过Executors静态工厂构建线程池，但一般不建议这样使用。关于这个问题，在那篇文章中并没有深入的展开。...我提到的是『不建议』，但是在阿里巴巴Java开发手册中也明确指出，而且用的词是『不允许』使用Executors创建线程池。 ? 阿里巴巴的规范手册里面说的是严令禁止使用的。...，在以上的代码中其实已经说了，真正的导致OOM的其实是LinkedBlockingQueue.offer方法。..., new ArrayBlockingQueue(10)); 这种情况下，一旦提交的线程数超过当前可用线程数时，就会抛出java.util.concurrent.RejectedExecutionException

2K2 0

【Java 线程池】Java 创建线程池的正确姿势： Executors 和 ThreadPoolExecutor 详解

终止并从缓存中移除那些已有 60 秒钟未被使用的线程。 newSingleThreadExecutor()创建一个单线程化的Executor。...其实，在上面的报错信息中，我们是可以看出蛛丝马迹的，在以上的代码中其实已经说了，真正的导致OOM的其实是LinkedBlockingQueue.offer方法。...而newFixedThreadPool中创建LinkedBlockingQueue时，并未指定容量。..., new ArrayBlockingQueue(10)); 这种情况下，一旦提交的线程数超过当前可用线程数时，就会抛出java.util.concurrent.RejectedExecutionException...但是异常（Exception）总比发生错误（Error）要好。除了自己定义ThreadPoolExecutor外。还有其他方法。这个时候第一时间就应该想到开源类库，如apache和guava等。

38.4K5 6

Tomcat 线程池学习总结

200)，minSpareThreads(最小线程数，即核心线程数，默认值 25)，maxIdleTime（线程最大空闲时间，毫秒为单位，默认值60秒），maxQueueSize(最大队列大小，默认值 Integer.MAX_VALUE...number of elements that can queue up before we reject them */ protected int maxQueueSize = Integer.MAX_VALUE...异常时，尝试再次将任务放入工作队列中。...org.apache.tomcat.util.threads.ThreadPoolExecutor public class ThreadPoolExecutor extends AbstractExecutorService...，并重写了offer（排队任务的方法），该方法中，当当前线程数大于核心线程数，小于最大线程数时，返回false，导致上述executeInternal方法中workQueue.offer(command

1.1K1 0

使用 Executors，ThreadPoolExecutor，创建线程池，源码分析理解

当然 Executors 也是用不同的参数去 new ThreadPoolExecutor 实现的，本文先分析前四种线程创建方式，后在分析 new ThreadPoolExecutor 创建方式使用...LinkedBlockingQueue队列中。...每当某个线程执行完成之后就从LinkedBlockingQueue队列中取一个。所以这个是创建固定大小的线程池。...由于corePoolSize为0所以任务会放入SynchronousQueue队列中，SynchronousQueue只能存放大小为1，所以会立刻新起线程，由于maxumumPoolSize为Integer.MAX_VALUE...2、当线程数大于等于 corePoolSize并且 workQueue 没有满时，放入workQueue中 3、线程数大于等于 corePoolSize并且当 workQueue 满时，新任务新建线程运行

85710 0

Java的ThreadPoolExecutor

)： ThreadPoolExecutor.AbortPolicy: 丢弃任务并抛出RejectedExecutionException异常。...3）线程执行完1）中的任务后，会循环中反复从LinkedBlockingQueue获取任务来执行。...())); } SingleThreadExecutor使用无界队列LinkedBlockingQueue作为线程池的工作队列（队列的容量为Integer.MAX_VALUE...3）线程执行完1中的任务后，会在一个无限循环中反复从LinkedBlockingQueue获取任务来执行。...线程的停止 1 单线程停止 Java虚拟机会先将该线程的中断标识位清除，然后抛出InterruptedException，因为在发生InterruptedException异常的时候，会清除中断标记。

7322 0

线程池的应用

如果正在运行的线程数等于corePoolSize时，则新任务被添加到队列中，直到队列满。当队列满了后，会继续开辟新线程来处理任务，但不超过最大线程数。...只能用ThreadPoolExecutor类，==不可以使用Executors创建== 阿里巴巴规范只能用ThreadPoolExecutor类，==不可以使用Executors创建== 为啥不允许呢？...public LinkedBlockingQueue() { this(Integer.MAX_VALUE); } 结论： 1）FixedThreadPool 和 SingleThreadPool...AbortPolicy（jdk默认策略） AbortPolicy -- 当任务添加到线程池中被拒绝时，它将抛出 RejectedExecutionException 异常。...DiscardOldestPolicy -- 当任务添加到线程池中被拒绝时，线程池会放弃等待队列中最旧的未处理任务，然后将被拒绝的任务添加到等待队列中。

4131 0

【Java】已解决java.util.concurrent.RejectedExecutionException异常

是Java并发编程中常见的一个异常，它通常发生在使用ExecutorService（如ThreadPoolExecutor）执行异步任务时，当任务提交到线程池但线程池无法处理新任务（比如，因为已经关闭了或者达到了其最大容量...在Web应用、后台服务或其他需要处理大量并发请求的系统中，经常可以看到此类异常的出现。下面，我们将探讨如何解决这一问题。...因为循环是无限的，线程池很快就会饱和，并且由于没有设置自定义的拒绝策略，当线程池无法接受新任务时，就会抛出RejectedExecutionException。...当线程池不能接受新任务时，它会尝试在调用execute的线程中运行该任务。五、注意事项在设计线程池时，要充分考虑系统的并发需求和资源限制，合理设置线程池的大小和队列容量。...对于需要长时间运行的任务，建议使用单独的线程或线程池来处理，避免阻塞核心线程池。在使用线程池时，要注意优雅地关闭线程池，避免资源泄露。

1.8K1 0

Java多线程：还不懂线程池吗？一文带你彻底搞懂！

通过线程池的execute()方法提交的Runnable对象将存储在该参数中。其采用阻塞队列实现。 threadFactory（可选）：线程工厂。用于指定为线程池创建新线程的方式。...4 线程池的参数 4.1 任务队列（workQueue）任务队列是基于阻塞队列实现的，即采用生产者消费者模式，在Java中需要实现BlockingQueue接口。...LinkedBlockingQueue：一个由链表结构组成的有界阻塞队列，在未指明容量时，容量默认为Integer.MAX_VALUE。...中，和LinkedBlockingQueue行为一致，但是是无界的阻塞队列。...注意有界队列和无界队列的区别：如果使用有界队列，当队列饱和时并超过最大线程数时就会执行拒绝策略；而如果使用无界队列，因为任务队列永远都可以添加任务，所以设置maximumPoolSize没有任何意义。

7430 0

线程池参数设计技巧

执行任务 DiscardPolicy 忽视，什么都不会发生 DiscardOldestPolicy 从队列中踢出最先进入队列（最后一个执行）的任务实现RejectedExecutionHandler...意思是队列里的线程可以等待1s，超过了的需要新开线程来执行切记不能设置为Integer.MAX_VALUE，这样队列会很大，线程数只会保持在corePoolSize大小，当任务陡增时，不能新开线程来执行...所以为了保证不出现的错误，使用这个类型队列的时候，maximumPoolSize一般指定成Integer.MAX_VALUE，即无限大 LinkedBlockingQueue...线程池的拒绝策略默认AbortPolicy ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。...)方法的时候就会一直阻塞,所以在开发中应该尽量使用带超时时间的get(); 发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/137654.html原文链接：https

4881 0

Java 多线程与线程池 Thread弊端与Executor存在问题及解决方法

在Java中可以通过线程池来达到这样的效果。什么时候使用线程池？单个任务处理时间比较短需要处理的任务数量很大使用线程池的好处: 降低资源消耗。...Executor存在问题在阿里巴巴Java开发手册中明确指出，不允许使用Executors创建线程池。 ?...其实，在上面的报错信息中，我们是可以看出蛛丝马迹的，在以上的代码中其实已经说了，真正的导致OOM的其实是LinkedBlockingQueue.offer方法。...而newFixedThreadPool中创建LinkedBlockingQueue时，并未指定容量。...但是异常（Exception）总比发生错误（Error）要好。除了自己定义ThreadPoolExecutor外。还有其他方法。这个时候第一时间就应该想到开源类库，如apache和guava等。

2.1K4 0

juc系列-Executor框架

工作队列可以有以下几种选择： (1).ArrayBlockingQueue：基于数组的有界阻塞队列 (2).LinkedBlockingQueue：基于链表的阻塞队列，可以不指定队列大小,默认Integer.MAX_VALUE...，直到达到线程池的最大数量，此时线程池的规模不再变化（如果某个线程发生Exception而结束，那么线程池会补充一个新的线程） newCachedThreadPool：创建一个可缓存的线程池，如果当前线程池中线程的个数超过了处理需求时...，那么空闲线程将被回收，而当需要增加线程时，则可以添加新的线程，线程池中个数不受限制（使用时格外注意，防止内存溢出） newSingleThreadPool：这是一个单线程的Executor，它创建单个工作线程来执行任务...---- 注意事项 1.newFixedThreadPool和newSingleThreadExecutor都是用了LinkedBlockingQueue(),默认capacity=Integer.MAX_VALUE...还提供了以下几个钩子函数用于扩展它的行为,我们可以在子类中实现自己的逻辑，在每个任务执行的前、后以及worker退出时进行定制处理。

5371 1

Java中的线程池用过吧？来说说你是怎么理解线程池吧？

前言 Java中的线程池用过吧？来说说你是怎么使用线程池的？这句话在面试过程中遇到过好几次了。我甚至这次标题都想写成【Java八股文之线程池】，但是有点太俗套了。...这一版的线程池，做到了在提交任务高峰时可临时扩容，低谷时又可及时回收非核心线程，从而节省资源。真正的做到了收放自如。通过上面几版线程池的改进，最终改进成了和Java中的线程池原理基本相似了。...所以当任务提交量高峰时，相当于无限制的创建线程。并且空闲时间是60秒，QPS高峰期最终会将服务器资源耗尽，所以真正实际应用中不建议使用。...当不能在处理提交的任务时，直接抛出RejectedExecutionException，使用者可以自行捕获此异常。...优先级队列，将会导致优先级最高的任务被抛弃，所以在阻塞队列为PriorityBlockingQueue时，不建议使用此策略。

6553 0

Java 多线程：彻底搞懂线程池

通过线程池的 execute() 方法提交的 Runnable 对象将存储在该参数中。其采用阻塞队列实现。 threadFactory（可选）：线程工厂。用于指定为线程池创建新线程的方式。...4 线程池的参数 4.1 任务队列（workQueue）任务队列是基于阻塞队列实现的，即采用生产者消费者模式，在 Java 中需要实现 BlockingQueue 接口。...LinkedBlockingQueue：一个由链表结构组成的有界阻塞队列，在未指明容量时，容量默认为 Integer.MAX_VALUE。...中，和 LinkedBlockingQueue 行为一致，但是是无界的阻塞队列。...注意有界队列和无界队列的区别：如果使用有界队列，当队列饱和时并超过最大线程数时就会执行拒绝策略；而如果使用无界队列，因为任务队列永远都可以添加任务，所以设置 maximumPoolSize 没有任何意义

7211 0

003. 线程池应用及实现原理剖析

为什么使用线程池？线程池是不是越多越好？ ---- 线程在 java 中是一个对象，更是操作系统的资源，线程创建、销毁需要时间。如果创建时间+销毁时间>执行任务时间就很不合算了。...工作线程：线程池中线程，在没有任务时处于等待状态，可以循环地执行任务。...当唯一的线程因任务异常中止时，将创建一个新的线程来继续执行后续的任务。...与 newFixedThreadPool(1) 的却别在于，单一线程池的池大小在 newSingleThreadExecutor 方法中硬编码，不能再改变的。...在使用 SynchronousQueue 作为工作队列的前提下，客户端代码向线程池提交任务时，而线程中又没有空闲的线程能够从 SynchronousQueue 队列中取出一个任务

3102 0

java并发线程池---了解ThreadPoolExecutor就够了

线程池-intsmaze 线程池的思想是：在系统中开辟一块区域，其中存放一些待命的线程，这个区域被称为线程池。...拒绝策略-intsmaze 线程池中的线程用完了，同时等待队列中的任务已经塞满了，再也塞不下新任务了，就需要拒绝策略:处理任务数量超过系统实际承受能力时，处理方式。...()); } newSingleThreadExecutor-intsmaze 任务队列LinkedBlockingQueue中（长度无限）,线程数量和最大线程数量均为1。...关闭线程池(很少使用，除了切换数据源时需要控制)-intsmaze 希望程序执行完所有任务后退出，调用ExecutorService接口中的shutdown(),shutdownNow()方法。...在《java并发编程实践》一书中给出了一个估算线程池大小的经验公式: Ncpu=CPU的数量 Ucpu=目标CPU的使用率，0<=Ucpu<=1 W/C=等待时间与计算时间的比率为保持处理器达到期望的使用率

2.9K1 0

Tomcat是如何修正JDK原生线程池bug的？

Tomcat 线程池原理其实ThreadPoolExecutor的参数主要有如下关键点：限制线程个数限制队列长度而Tomcat对这俩资源都需要限制，否则高并发下CPU、内存都有被耗尽可能...(); Tomcat线程池使用 submittedCount 变量维护已提交到线程池，但未执行完的任务数量。...Tomcat的任务队列TaskQueue扩展了JDK的LinkedBlockingQueue，Tomcat给了它一个capacity，传给父类LinkedBlockingQueue的构造器。...super(capacity); } ... } capacity参数通过Tomcat的maxQueueSize参数设置，但maxQueueSize默认值Integer.MAX_VALUE：当前线程数达到核心线程数后...为解决该问题，TaskQueue重写了LinkedBlockingQueue#offer，在合适时机返回false，表示任务添加失败，这时线程池就会创建新线程。什么叫合适时机？

7532 0

点击加载更多

为什么线程池不允许使用Executors去创建？

阿里面试官鬼得很，问我为什么他们阿里要禁用Executors创建线程池？

多线程的使用，避免ExecutorService 的创建处理

还在用Executors创建线程池？小心内存溢出

【小家java】Java中的线程池，你真的用对了吗？（教你用正确的姿势使用线程池,Executors使用中的坑）

【Java 线程池】Java 创建线程池的正确姿势： Executors 和 ThreadPoolExecutor 详解

Tomcat 线程池学习总结

使用 Executors，ThreadPoolExecutor，创建线程池，源码分析理解

Java的ThreadPoolExecutor

线程池的应用

【Java】已解决java.util.concurrent.RejectedExecutionException异常

Java多线程：还不懂线程池吗？一文带你彻底搞懂！

线程池参数设计技巧

Java 多线程与线程池 Thread弊端与Executor存在问题及解决方法

juc系列-Executor框架

Java中的线程池用过吧？来说说你是怎么理解线程池吧？

Java 多线程：彻底搞懂线程池

003. 线程池应用及实现原理剖析

java并发线程池---了解ThreadPoolExecutor就够了

Tomcat是如何修正JDK原生线程池bug的？

相关资讯

热门标签

活动推荐

运营活动

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐