Java 线程池newFixedThreadPool、newCachedThreadPool

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。

线程池默认策略