多线程的使用，避免ExecutorService 的创建处理

​ ​

前言：
最近在开发的时候，在使用多线程的时候，发现了一些问题，不正确的使用，会产生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
 */
public class demo {

    //错误的创建线程的方式
    private static ExecutorService executorService= Executors.newFixedThreadPool(15);
    //正确的创建线程的方式
    private static ExecutorService executor = new ThreadPoolExecutor(10, 10,
            60L, TimeUnit.SECONDS,
            new ArrayBlockingQueue(10));
    public static void main(String[] args){
        for(int i=0;i<Integer.MAX_VALUE;i++)
        {
            executor.execute(new SubThread());
        }
    }

​

class SubThread implements Runnable{

    @Override
    public void run(){
        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 来创建线程池。

异常截图

​

​编辑​

​