前言: 最近在开发的时候,在使用多线程的时候,发现了一些问题,不正确的使用,会产生oom的情况,后面看了阿里巴巴的开发手册,亲自验证了一下问题点 ,解决了问题,特别mark一下 代码: package com.ly.tcgl.sellservice.web.controller;import com.google.common.util.concurrent.ThreadFactoryBuilder;import org.apache.tomcat.util.threads.ThreadPoolExecutor;import java.util.concurrent.*;/** * @title: 多线程的使用方式,遵守阿里巴巴的规则,否则的话容易产生oom(outofmemory) * @Author like.ma * @Date: 2020-09-11 11:16 * @Version 1.0 */publicclassdemo{ //错误的创建线程的方式 privatestatic ExecutorService executorService= Executors.newFixedThreadPool(15); //正确的创建线程的方式 privatestatic ExecutorService executor =newThreadPoolExecutor(10,10, 60L, TimeUnit.SECONDS, newArrayBlockingQueue(10)); publicstaticvoidmain(String[] args){ for(int i=0;i<Integer.MAX_VALUE;i++) { executor.execute(newSubThread()); } }
classSubThreadimplementsRunnable{ @Override publicvoidrun(){ try{ Thread.sleep(100); } catch(InterruptedException e){ System.out.println(e); } }}
第一种方式,
如果读者对Java 中的阻塞队列有所了解的话,看到这里或许就能够明白原 因了。 Java 中的BlockingQueue 主要有两种实现, 分别是ArrayBlockingQueue 和 LinkedBlockingQueue。 ArrayBlockingQueue 是一个用数组实现的有界阻塞队列,必须设置容量。 LinkedBlockingQueue 是一个用链表实现的有界阻塞队列,容量可以选择 进行设置,不设置的话,将是一个无边界的阻塞队列,最大长度为Integer.MAX_ VALUE。 这里的问题就出在:不设置的话,将是一个无边界的阻塞队列,最大长度为 为什么阿里巴巴禁止使用Executors 创建线程池? < 35 Integer.MAX_VALUE。也就是说,如果我们不设置LinkedBlockingQueue 的 容量的话,其默认容量将会是Integer.MAX_VALUE。 而newFixedThreadPool 中创建LinkedBlockingQueue 时,并未指定容 量。此时,LinkedBlockingQueue 就是一个无边界队列,对于一个无边界队列 来说,是可以不断的向队列中加入任务的,这种情况下就有可能因为任务过多而导 致内存溢出问题。 上面提到的问题主要体现在newFixedThreadPool 和newSingleThreadExecutor 两个工厂方法上,并不是说newCachedThreadPool 和newScheduledThreadPool 这两个方法就安全了,这两种方式创建的最大线程数可能是 Integer.MAX_VALUE,而创建这么多线程,必然就有可能导致OOM。
使用过程,会产生oom的情况,进行内存溢出的情况,直接电脑的内存耗尽;
第二种方式,会产生异常,不会产生oom的情况,推荐使用第二种,
避免使用Executors 创建线程池,主要是避免使用其中的默认实现,那么我们 可以自己直接调用ThreadPoolExecutor 的构造函数来自己创建线程池。在创建的 同时,给BlockQueue 指定容量就可以了。 private static ExecutorService executor = new ThreadPoolExecutor(10, 10, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue(10)); 这种情况下,一旦提交的线程数超过当前可用线程数时,就会抛出java.util. concurrent.RejectedExecutionException,这是因为当前线程池使用的队列 是有边界队列,队列已经满了便无法继续处理新的请求。但是异常(Exception)总比 发生错误(Error)要好。 除了自己定义ThreadPoolExecutor 外。还有其他方法。这个时候第一时间 就应该想到开源类库,如apache 和guava 等。 作者推荐使用guava 提供的ThreadFactoryBuilder 来创建线程池。
异常截图
编辑