Java 线程池newFixedThreadPool、newCachedThrea…

2020-04-14 16:07:51来源:博客园 阅读 ()

新老客户大回馈,云服务器低至5折

Java 线程池newFixedThreadPool、newCachedThreadPoo

newFixedThreadPool

@Slf4j
public class TheadPoolDemo {
    private static ThreadPoolExecutor threadPool = (ThreadPoolExecutor) Executors.newFixedThreadPool(10);

    public static void newFixedThreadPool() throws Exception {
        for (int i = 0; i < 2000000000; i++) {
            threadPool.execute(() ->
            {
                String payload = IntStream.rangeClosed(1, 90000000).mapToObj(__ -> "a").collect(Collectors.joining("")) + UUID.randomUUID().toString();
                try {
                    TimeUnit.HOURS.sleep(1);
                } catch (InterruptedException e) {
                }
                log.info(payload);
            });
        }
        threadPool.shutdown();
        threadPool.awaitTermination(1, TimeUnit.HOURS);
    }


}

运行一段时间后oom

 

 原因分析

 

无界队列

 

 果任务较多并且执行较慢的话,队列可能会快速积压,撑爆内存导致 OOM

newCachedThreadPoo

 private static ThreadPoolExecutor threadPoolCached = (ThreadPoolExecutor) Executors.newCachedThreadPool();

    public static void newCachedThreadPool() throws Exception {
        for (int i = 0; i < 2000000000; i++) {
            threadPoolCached.execute(() ->
            {
                String payload = IntStream.rangeClosed(1, 90000000).mapToObj(__ -> "a").collect(Collectors.joining("")) + UUID.randomUUID().toString();
                try {
                    TimeUnit.HOURS.sleep(1);
                } catch (InterruptedException e) {
                }
                log.info(payload);
            });
        }
        threadPool.shutdown();
        threadPool.awaitTermination(1, TimeUnit.HOURS);
    }

运行一段时间后oom

 

  原因分析

 

 

 

这种线程池的最大线程数是 Integer.MAX_VALUE,可以认为是没有上限的,而其工作队列 SynchronousQueue 是一个没有存储空间的阻塞队列。

这意味着,只要有请求到来,就必须找到一条工作线程来处理,如果当前没有空闲的线程就再创建一条新的。

大量的任务进来后会创建大量的线程。线程是需要分配一定的内存空间作为线程栈的,比如 1MB,因此无限制创建线程必然会导致 OOM。

线程池默认策略

 


原文链接:https://www.cnblogs.com/Brake/p/12702234.html
如有疑问请与原作者联系

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有

上一篇:Mybatis+Oracle搭配insert空值报错之myBatis+mysql驱动+oracle驱

下一篇:ArrayList、LinkedList和Vector源码分析