Java 线程池newFixedThreadPoolnewCachedThreadPoo

Posted 2021-03-01

Catch Spark. Code

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Java 线程池newFixedThreadPoolnewCachedThreadPoo相关的知识，希望对你有一定的参考价值。

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

newCachedThreadPool

 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。

线程池默认策略

 

以上是关于Java 线程池newFixedThreadPoolnewCachedThreadPoo的主要内容，如果未能解决你的问题，请参考以下文章

Java线程池

java创建线程池都有哪些

java线程池

java线程池原理

JAVA线程池使用哪一种比较好

如何使用java语言实现一个线程池，不使用jdk自带的线程池