当前位置:   article > 正文

【Java进阶】线程池之无限线程数 - Executors.newCachedThreadPool() ,创建无限线程数线程池

executors.newcachedthreadpool()

线程池底层实现

线程池的底层实现是:ThreadPoolExecutor

使用工厂类Executors快速创建预定义线程池

IDEA插件Alibaba Java Coding Guidelines,代码提示如下(马云不推荐使用啊)

线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。
说明:Executors 返回的线程池对象的弊端如下:
1) FixedThreadPool 和 SingleThreadPool:
允许的请求队列长度为 Integer.MAX_VALUE(无限),可能会堆积大量的请求,从而导致 OOM。
2) CachedThreadPool:
允许的创建线程数量为 Integer.MAX_VALUE(无限),可能会创建大量的线程,从而导致 OOM。

预定义线程池

2. CachedThreadPool(典型的最大线程数是无限的线程池)

允许的创建线程数量为 Integer.MAX_VALUE(无限),可能会创建大量的线程,从而导致 OOM。

ExecutorService executorService = Executors.newCachedThreadPool();

  1. //点击进入代码,查看实现:
  2. public static ExecutorService newCachedThreadPool() {
  3. return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
  4. 60L, TimeUnit.SECONDS,
  5. new SynchronousQueue<Runnable>());
  6. }
  1. 第一种写法(最简单):使用工厂类Executors快速创建线程池
  2. ExecutorService executorService = Executors.newCachedThreadPool();
  3. 第二种写法(最原始):使用ExecutorService创建线程池
  4. ExecutorService pool = new ThreadPoolExecutor(
  5. 0, //corePoolSize = 0
  6. Integer.MAX_VALUE, //maximumPoolSize = 2147483647
  7. 60L, //keepAliveTime = 60
  8. TimeUnit.MILLISECONDS,
  9. new SynchronousQueue<Runnable>(),
  10. Executors.defaultThreadFactory(),
  11. new ThreadPoolExecutor.AbortPolicy());
  12. 第三种写法(适中):使用ThreadPoolTaskExecutor简洁创建线程池
  13. ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
  14. poolTaskExecutor.setQueueCapacity(0); //这个地方随便填
  15. poolTaskExecutor.setCorePoolSize(0); //核心线程数是0,阻塞队列会选择new SynchronousQueue()
  16. poolTaskExecutor.setMaxPoolSize(2147483647); // Integer.MAX_VALUE = 2147483647
  17. poolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
  18. poolTaskExecutor.setKeepAliveSeconds(60);
  19. poolTaskExecutor.initialize();

扩展参考: 线程池之CachedThreadPool学习

 

 

 

 

 

 

声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号