Java中线程池，你真的了解会用吗

在《 深刻源码分析Java线程池的实现原理 》这篇文章中，咱们介绍过了Java中线程池的常见用法以及基本原理。

在文中有这样一段描述：

能够经过Executors静态工厂构建线程池，但通常不建议这样使用。

关于这个问题，在那篇文章中并无深刻的展开。做者之因此这么说，是由于这种建立线程池的方式有很大的隐患，稍有不慎就有可能致使线上故障，如：一次Java线程池误用引起的血案和总结（ zhuanlan.zhihu.com/p/32867181 ）

本文咱们就来围绕这个问题来分析一下为何JDK自身提供的构建线程池的方式并不建议使用？到底应该如何建立一个线程池呢？

Executors {#toc_0}

Executors 是一个Java中的工具类。提供工厂方法来建立不一样类型的线程池。



从上图中也能够看出，Executors的建立线程池的方法，建立出来的线程池都实现了ExecutorService接口。经常使用方法有如下几个：

newFiexedThreadPool(int Threads) ：建立固定数目线程的线程池。

newCachedThreadPool() ：建立一个可缓存的线程池，调用execute 将重用之前构造的线程（若是线程可用）。若是没有可用的线程，则建立一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

newSingleThreadExecutor() 建立一个单线程化的Executor。

newScheduledThreadPool(int corePoolSize) 建立一个支持定时及周期性的任务执行的线程池，多数状况下可用来替代Timer类。

类看起来功能仍是比较强大的，又用到了工厂模式、又有比较强的扩展性，重要的是用起来还比较方便，如：

ExecutorService executor = Executors.newFixedThreadPool(nThreads) ;

复制代码

便可建立一个固定大小的线程池。

可是为何我说不建议你们使用这个类来建立线程池呢？

我提到的是『不建议』，可是在阿里巴巴Java开发手册中也明确指出，并且用的词是『不容许』使用Executors建立线程池。



Executors存在什么问题 {#toc_1}

在阿里巴巴Java开发手册中提到，使用Executors建立线程池可能会致使OOM(OutOfMemory ,内存溢出)，可是并无说明为何，那么接下来咱们就来看一下到底为何不容许使用Executors？

咱们先来一个简单的例子，模拟一下使用Executors致使OOM的状况。

/** *@authorHollis */

publicclassExecutorsDemo

{privatestaticExecutorService executor = Executors.newFixedThreadPool(15);

publicstaticvoidmain(String[] args){for(inti =0; i < Integer.MAX_VALUE; i++)

{            executor.execute(newSubThread());        }    }}classSubThreadimplementsRunnable{@Overridepublicvoidrun()

{try{            Thread.sleep(10000);        }catch(InterruptedException e) {//do nothing}    }}复制代码

经过指定JVM参数： -Xmx8m -Xms8m 运行以上代码，会抛出OOM:

Exceptioninthread"main"java.lang.OutOfMemoryError:GCoverheadlimitexceeded at

java.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:416) at

java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1371)

atcom.hollis.ExecutorsDemo.main(ExecutorsDemo.java:16)复制代码

以上代码指出， ExecutorsDemo.java 的第16行，就是代码中的 executor.execute(new SubThread()); 。

Executors为何存在缺陷 {#toc_2}

经过上面的例子，咱们知道了 Executors 建立的线程池存在OOM的风险，那么究竟是什么缘由致使的呢？咱们须要深刻 Executors 的源码来分析一下。

其实，在上面的报错信息中，咱们是能够看出蛛丝马迹的，在以上的代码中其实已经说了，真正的致使OOM的实际上是 LinkedBlockingQueue.offer 方法。

Exceptioninthread"main"java.lang.OutOfMemoryError:GCoverheadlimitexceededatjava.util.concurrent.LinkedBlockingQueue.offer(LinkedBlockingQueue.java:416)atjava.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1371)atcom.hollis.ExecutorsDemo.main(ExecutorsDemo.java:16)复制代码

若是读者翻看代码的话，也能够发现，其实底层确实是经过 LinkedBlockingQueue 实现的：

publicstaticExecutorServicenewFixedThreadPool(intnThreads)

returnnewThreadPoolExecutor

(nThreads, nThreads,0L, TimeUnit.MILLISECONDS,newLinkedBlockingQueue());复制代码

若是读者对Java中的阻塞队列有所了解的话，看到这里或许就可以明白缘由了。

Java中的 BlockingQueue 主要有两种实现，分别是 ArrayBlockingQueue 和 LinkedBlockingQueue 。

ArrayBlockingQueue 是一个用数组实现的有界阻塞队列，必须设置容量。

LinkedBlockingQueue 是一个用链表实现的有界阻塞队列，容量能够选择进行设置，不设置的话，将是一个无边界的阻塞队列，最大长度为 Integer.MAX_VALUE 。

这里的问题就出在：**不设置的话，将是一个无边界的阻塞队列，最大长度为Integer.MAX_VALUE。**也就是说，若是咱们不设置 LinkedBlockingQueue 的容量的话，其默认容量将会是 Integer.MAX_VALUE 。

而 newFixedThreadPool 中建立 LinkedBlockingQueue 时，并未指定容量。此时， LinkedBlockingQueue 就是一个无边界队列，对于一个无边界队列来讲，是能够不断的向队列中加入任务的，这种状况下就有可能由于任务过多而致使内存溢出问题。

上面提到的问题主要体如今 newFixedThreadPool 和 newSingleThreadExecutor 两个工厂方法上，并非说 newCachedThreadPool 和 newScheduledThreadPool 这两个方法就安全了，这两种方式建立的最大线程数多是 Integer.MAX_VALUE ，而建立这么多线程，必然就有可能致使OOM。在此我向你们推荐一个架构学习交流群。交流学习群号：821169538  里面会分享一些资深架构师录制的视频录像：有Spring，MyBatis，Netty源码分析，高并发、高性能、分布式、微服务架构的原理，JVM性能优化、分布式架构等这些成为架构师必备的知识体系。还能领取免费的学习资源，目前受益良多。

建立线程池的正确姿式 {#toc_3}

避免使用Executors建立线程池，主要是避免使用其中的默认实现，那么咱们能够本身直接调用 ThreadPoolExecutor 的构造函数来本身建立线程池。在建立的同时，给 BlockQueue 指定容量就能够了。

privatestaticExecutorService executor =newThreadPoolExecutor(10,10,60L, TimeUnit.SECONDS,newArrayBlockingQueue(10));复制代码

这种状况下，一旦提交的线程数超过当前可用线程数时，就会抛出 java.util.concurrent.RejectedExecutionException ，这是由于当前线程池使用的队列是有边界队列，队列已经满了便没法继续处理新的请求。可是异常（Exception）总比发生错误（Error）要好。

除了本身定义 ThreadPoolExecutor 外。还有其余方法。这个时候第一时间就应该想到开源类库，如apache和guava等。

做者推荐使用guava提供的ThreadFactoryBuilder来建立线程池。

publicclassExecutorsDemo{privatestaticThreadFactory namedThreadFactory =newThreadFactoryBuilder()        .setNameFormat("demo-pool-%d").build();privatestaticExecutorService pool =newThreadPoolExecutor(5,200,0L, TimeUnit.MILLISECONDS,newLinkedBlockingQueue(1024), namedThreadFactory,newThreadPoolExecutor.AbortPolicy());publicstaticvoidmain(String[] args){for(inti =0; i < Integer.MAX_VALUE; i++) {            pool.execute(newSubThread());        }    }}复制代码

经过上述方式建立线程时，不只能够避免OOM的问题，还能够自定义线程名称，更加方便的出错的时候溯源。

思考题，文中做者说：发生异常（Exception）要比发生错误（Error）好，为何这么说？