为什么阿里要禁用 Executors 建设线程池？

发布时间：2019-11-14 03:00:23 所属栏目：建站来源：佚名

导读：【线上直播】11月21日晚8点贝壳技能总监侯圣文《数据安详之数据库安详黄金法例》看阿里巴巴开拓手册并发编程这块有一条：线程池不应承行使Executors去建设，而是通过ThreadPoolExecutor的方法，通过源码说明禁用的缘故起因。写在前面起首感激各人在盖楼的间

CachedThreadPool是一个按照必要建设新线程的线程池

corePoolSize => 0，焦点线程池的数目为0
maximumPoolSize => Integer.MAX_VALUE，可以以为最大线程数是无穷的
keepAliveTime => 60L
unit => 秒
workQueue => SynchronousQueue

当一个使命提交时，corePoolSize为0不建设焦点线程，SynchronousQueue是一个不存储元素的行列，可以领略为队里永久是满的，因此最终会建设非焦点线程来执利用命。

对付非焦点线程空闲60s时将被接纳。由于Integer.MAX_VALUE很是大，可以以为是可以无穷建设线程的，在资源有限的环境下轻易引起OOM非常

Executors#newSingleThreadExecutor要领

public static ExecutorService newSingleThreadExecutor() { 
    return new FinalizableDelegatedExecutorService 
        (new ThreadPoolExecutor(1, 1, 
                                0L, TimeUnit.MILLISECONDS, 
                                new LinkedBlockingQueue<Runnable>())); 
}

SingleThreadExecutor是单线程线程池，只有一个焦点线程

corePoolSize => 1，焦点线程池的数目为1
maximumPoolSize => 1，只可以建设一个非焦点线程
keepAliveTime => 0L
unit => 秒
workQueue => LinkedBlockingQueue

当一个使命提交时，起首会建设一个焦点线程来执利用命，假如高出焦点线程的数目，将会放入行列中，由于LinkedBlockingQueue是长度为Integer.MAX_VALUE的行列，可以以为是无界行列，因此往行列中可以插入无穷多的使命，在资源有限的时辰轻易引起OOM非常，同时由于无界行列，maximumPoolSize和keepAliveTime参数将无效，压根就不会建设非焦点线程

Executors#newFixedThreadPool要领

public static ExecutorService newFixedThreadPool(int nThreads) { 
    return new ThreadPoolExecutor(nThreads, nThreads, 
                                  0L, TimeUnit.MILLISECONDS, 
                                  new LinkedBlockingQueue<Runnable>()); 
}

FixedThreadPool是牢靠焦点线程的线程池，牢靠焦点线程数由用户传入

corePoolSize => 1，焦点线程池的数目为1
maximumPoolSize => 1，只可以建设一个非焦点线程
keepAliveTime => 0L
unit => 秒
workQueue => LinkedBlockingQueue
它和SingleThreadExecutor相同，独一的区别就是焦点线程数差异，而且因为行使的是LinkedBlockingQueue，在资源有限的时辰轻易引起OOM非常

总结：

FixedThreadPool和SingleThreadExecutor => 应承的哀求行列长度为Integer.MAX_VALUE，也许会会萃大量的哀求，从而引起OOM非常
CachedThreadPool => 应承建设的线程数为Integer.MAX_VALUE，也许会建设大量的线程，从而引起OOM非常

这就是为什么榨取行使Executors去建设线程池，而是保举本身去建设ThreadPoolExecutor的缘故起因

OOM非常测试

理论上会呈现OOM非常，必需测试一波验证之前的说法：

测试类：TaskTest.java

public class TaskTest { 
    public static void main(String[] args) { 
        ExecutorService es = Executors.newCachedThreadPool(); 
        int i = 0; 
        while (true) { 
            es.submit(new Task(i++)); 
        } 
    } 
}

行使Executors建设的CachedThreadPool，往线程池中无穷添加线程

在启动测试类之前先将JVM内存调解小一点，否则很轻易将电脑跑出题目【别问我为什么知道，是铁憨憨甜没错了!!!】，在idea里：Run -> Edit Configurations