每天都在用，但你知道 Tomcat 的线程池有多努力吗？
摘要：在截图的 1371 行，如果没有把任务成功放到队列里面（前提是线程池是运行状态），则会执行 1378 行的逻辑，而这个逻辑，就是创建非核心线程的逻辑。但是这个地方需要多说一句的是，如果当已经提交但是还未完成的任务的数量小于线程池中运行线程的数量时，Tomcat 的做法是把任务放到队列里面去，而不是立即执行。
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8"/><div>
<div>
<div>
持续输出原创文章，点击蓝字关注我吧
<div/>
</div>
大家好，我是 why，一个四川程序猿，成都好男人。
先是本号的特色，技术分享之前先简短的荒腔走板聊聊生活。让文章的温度更多一点点。
上面的图是我在一次跑步的过程中拍的。活动之前赛事方搞了个留言活动，收集每公里路牌的一个宣传语。
我的留言有幸被选中了：
每人知道你在坚持什么，但你自己心里应该清楚。
是在说跑马拉松，也是在说其他的事情。
我记得那天的太阳，骄阳似火，路上的树荫也非常的少。苦就苦在我还报的是超级马拉松（说是超级马拉松，其实就是一个全马 42 km加最后 3 km纯上坡的马拉松）
到底有多晒，我给你看一下对比：
<p style="text-align:center">
<img src="https://img2.tuicool.com/UrERjqZ.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
酷暑难耐，以至于 30 公里左右的地方我的心里出现了两个小人：
一个说：我好累啊，我跑不动了，我要退赛。
一个说：好呀好呀，我也好晒啊，退赛退赛。
我说：呸，看你们两个不争气的东西，让我带你去终点
于是在 36 公里的地方碰到了我提交的标语，非常开心，停下来拍了几张照片。给自己说：坚持不住的时候再坚持一下。
最后的 3 公里上坡，抽筋了不知道多少次。远远看见终点拱门的时候我突然想到了在敦煌的时候悟出的一句话：自己给自己的辛苦，不是辛苦，是幸福。
好了，说回文章。
先用 JDK 线程池来开个题。
正确回答在之前的文章中回答了，这里不在赘述。
但是我面试的时候曾经遇到过很多对于 JDK 线程池不了解的朋友。
而这些人当中大多数都有一个通病，那就是遇到不太会的问题，那就去猜。
面试者遇到这个不会的题的时候，表面上微微一笑，实际上我都已经揣摩出他们的内心活动了：
MD，这题我没背过呀，但是刚刚听面试官说核心线程数是 10，最大线程数是 30。看题也知道答案不是 10 就是 30。
选择题，百分之 50 的命中率，难道不赌一把？
等等，30 是最大线程数？最大？我感觉就是它了。
于是在电光火石一瞬间的思考后，和我对视起来，自信的说：
<p style="text-align:center">
<img src="https://img2.tuicool.com/ZfMneiu.jpg!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
于是我也是微微一笑，告诉他：下去再了解一下吧，我们聊聊别的。
<p style="text-align:center">
<img src="https://img2.tuicool.com/RzE3UjU.gif" referrerpolicy="no-referrer"/>
</p>
可惜 JDK 的线程池，就是反直觉的。
那有符合我们直觉的线程池吗？
<h4>有的，你经常用的的 Tomcat ，它里面的线程池的运行过程就是先把最大线程数用完，然后再提交任务到队列里面去的。</h4>
我带你剖析一下。
先打开 Tomcat 的 server.xml 看一下：
<p style="text-align:center">
<img src="https://img2.tuicool.com/INBZzuZ.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
眼熟吧？哪一个学过 java web 的人没有配置过这个文件？哪一个配置过这个文件的人没有留意过 Executor 配置？
具体的可配置项可以查看官方文档：
http://tomcat.apache.org/tomcat-9.0-doc/config/executor.html
同时我找到一个可配置的参数的中文说明如下：
<p style="text-align:center">
<img src="https://img1.tuicool.com/EzqUVfY.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<h4>注意其中的第一个参数是 className，图片中少了个字母 c。</h4>
然后还有两个参数没有介绍，我补充一下：
<ol>
<li>
<p class="no-text-indent">prestartminSpareThreads：boolean 类型，当服务器启动时，是否要创建出最小空闲线程（核心线程）数量的线程，默认值为 false 。</p>
</li>
<li>
<p class="no-text-indent">
org.apache.catalina.core.StandardThreadExecutor我们先解读一下这个方法（ 注意，本文中 Tomcat 源码版本号为：10.0.0-M 4 ）：
org.apache.catalina.core.StandardThreadExecutor#startInternal
<img src="https://img2.tuicool.com/jYfyy2E.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
从 123 行到 130 行，就是构建 Tomcat 线程池的地方，很关键，我解读一下：
123行
<pre class="prettyprint">taskqueue = new TaskQueue(maxQueueSize);</pre>
创建一个 TaskQueue 队列，这个队列是继承自 LinkedBlockingQueue 的：
<p style="text-align:center">
<img src="https://img0.tuicool.com/QBRFvqi.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
该队列上的注释值得关注一下：
主要是说这是一个专门为线程池设计的一个任务队列。配合线程池使用的时候和普通队列有不一样的地方。
同时传递了一个队列长度，默认为 Integer.MAX_VALUE：
<p style="text-align:center">
<img src="https://img0.tuicool.com/vymeyu2.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
124行
<pre class="prettyprint">TaskThreadFactory tf = new TaskThreadFactory(namePrefix,daemon,getThreadPriority());</pre>
构建一个 ThreadFactory，其三个入参分为如下：
<p style="text-align:center">
<img src="https://img2.tuicool.com/A3uQVfQ.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<ol>
<li>
<p class="no-text-indent">namePrefix：名称前缀。可以指定，其默认是“tomcat-exec-”。 </p>
</li>
<li>
<p class="no-text-indent">daemon：是否以守护线程模式启动。默认是 true。</p>
</li>
<li>
<p class="no-text-indent">priority：线程优先级。是一个 1 到 10 之前的数，默认是 5。</p>
</li>
</ol>
125行
<pre class="prettyprint">executor = new ThreadPoolExecutor(getMinSpareThreads(), getMaxThreads(), maxIdleTime, TimeUnit.MILLISECONDS,taskqueue, tf);</pre>
构建线程池，其 6 个入参分别如下：
<p style="text-align:center">
<img src="https://img1.tuicool.com/ZZZ3Efi.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
这个具体含义我就不解释了，和 JDK 线程池是一样的。
只是给大家看一下默认参数。
<p style="text-align:center">
<img src="https://img0.tuicool.com/Rn2Ub2A.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
另外还需要十分注意的一点是，这里的 ThreadPoolExecuteor 是 Tomcat 的，不是 JDK 的，虽然名字一样。
<p style="text-align:center">
<img src="https://img2.tuicool.com/aeEbyuj.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
126行
executor.setThreadRenewalDelay(threadRenewalDelay);
设置 threadRenewalDelay 参数。不是本文重点，可以先不关心。
127 - 129行
<pre class="prettyprint"><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(224, 108, 117);width:13px;font-style:normal;">if</span> (prestartminSpareThreads) {<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(224, 108, 117);width:53px;font-style:normal;">executor</span><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(209, 154, 102);width:152px;font-style:normal;">.prestartAllCoreThreads</span>();<br mpa-from-tpl="t"/>}</pre>
设置是否预启动所有的核心线程池，这个参数在之前文章中也有讲到过。
<span>prestartminSpareThreads</span>
为什么呢？ 因为在 125 行构建线程池的时候已经调用过这个方法了：
从源码可以看出，不管你调用哪一个线程池构造方法，都会去调用 prestartAllCoreThreads 方法。
所以，这算不算 Tomcat 的一个小 Bug 呢？快拿起你的键盘给它提 pr 吧。
130行
<pre class="prettyprint">taskqueue.setParent(executor);</pre>
这行代码非常关键。没有这行代码，Tomcat 的线程池则会表现的和 JDK 的线程池一样。
拿下面的程序举例：
<p style="text-align:center">
<img src="https://img1.tuicool.com/VjUBRvF.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
自定义线程池最多可以容纳 150+300 个任务。
当 24 行注释的时候，Tomcat 线程池运行的过程和 JDK 线程池的运行过程一样，运行的线程数只会是核心程序数 5。
当 24 行取消注释的时候，Tomcat 线程池就会一直创建线程个数到 150 个，然后把剩下的任务提交到自定义的 TaskQueue 队列里面去。
我再提供一个复制粘贴直接运行版本，你分别运行一下，试一试，看看结果：
<pre class="prettyprint"><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:39px;font-style:normal;">public</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:231px;font-style:normal;"><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:33px;font-style:normal;">class</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:184px;font-style:normal;">TomcatThreadPoolExecutorTest</span> </span>{<br mpa-from-tpl="t"/><br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:442px;font-style:normal;"><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:40px;font-style:normal;">public</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:40px;font-style:normal;">static</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:26px;font-style:normal;">void</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:26px;font-style:normal;">main</span><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:99px;font-style:normal;">(String[] args)</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:39px;font-style:normal;">throws</span> InterruptedException </span>{<br mpa-from-tpl="t"/> String namePrefix = <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:120px;font-style:normal;">"why不止技术-exec-"</span>;<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:46px;font-style:normal;">boolean</span> daemon = <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:26px;font-style:normal;">true</span>;<br mpa-from-tpl="t"/> TaskQueue taskqueue = <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:20px;font-style:normal;">new</span> TaskQueue(<span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:20px;font-style:normal;">300</span>);<br mpa-from-tpl="t"/> TaskThreadFactory tf = <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:20px;font-style:normal;">new</span> TaskThreadFactory(namePrefix, daemon, Thread.NORM_PRIORITY);<br mpa-from-tpl="t"/> ThreadPoolExecutor executor = <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:19px;font-style:normal;">new</span> ThreadPoolExecutor(<span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:7px;font-style:normal;">5</span>,<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:20px;font-style:normal;">150</span>, <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:33px;font-style:normal;">60000</span>, TimeUnit.MILLISECONDS, taskqueue, tf);<br mpa-from-tpl="t"/><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(87, 166, 74);width:264px;font-style:italic;"> //taskqueue.setParent(executor);</span><br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:19px;font-style:normal;">for</span> (<span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:19px;font-style:normal;">int</span> i = <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:7px;font-style:normal;">0</span>; i < <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:19px;font-style:normal;">300</span>; i++) {<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:20px;font-style:normal;">try</span> {<br mpa-from-tpl="t"/> executor.execute(() -> {<br mpa-from-tpl="t"/> logStatus(executor, <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:61px;font-style:normal;">"创建任务"</span>);<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:20px;font-style:normal;">try</span> {<br mpa-from-tpl="t"/> TimeUnit.SECONDS.sleep(<span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(184, 215, 163);width:7px;font-style:normal;">2</span>);<br mpa-from-tpl="t"/> } <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:33px;font-style:normal;">catch</span> (InterruptedException e) {<br mpa-from-tpl="t"/> e.printStackTrace();<br mpa-from-tpl="t"/> }<br mpa-from-tpl="t"/> });<br mpa-from-tpl="t"/> } <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:33px;font-style:normal;">catch</span> (Exception e) {<br mpa-from-tpl="t"/> e.printStackTrace();<br mpa-from-tpl="t"/> }<br mpa-from-tpl="t"/> }<br mpa-from-tpl="t"/> Thread.currentThread().join();<br mpa-from-tpl="t"/> }<br mpa-from-tpl="t"/><br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:475px;font-style:normal;"><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:46px;font-style:normal;">private</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:40px;font-style:normal;">static</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(86, 156, 214);width:27px;font-style:normal;">void</span> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:60px;font-style:normal;">logStatus</span><span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(220, 220, 220);width:277px;font-style:normal;">(ThreadPoolExecutor executor, String name)</span> </span>{<br mpa-from-tpl="t"/> TaskQueue queue = (TaskQueue) executor.getQueue();<br mpa-from-tpl="t"/> System.out.println(Thread.currentThread().getName() + <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:20px;font-style:normal;">"-"</span> + name + <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:26px;font-style:normal;">"-:"</span> +<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:80px;font-style:normal;">"核心线程数:"</span> + executor.getCorePoolSize() +<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:93px;font-style:normal;">"\t活动线程数:"</span> + executor.getActiveCount() +<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:93px;font-style:normal;">"\t最大线程数:"</span> + executor.getMaximumPoolSize() +<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:81px;font-style:normal;">"\t总任务数:"</span> + executor.getTaskCount() +<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:117px;font-style:normal;">"\t当前排队线程数:"</span> + queue.size() +<br mpa-from-tpl="t"/> <span style="background:rgba(0, 0, 0, 0);font-weight:400;display:inline;text-decoration:none solid rgb(214, 157, 133);width:105px;font-style:normal;">"\t队列剩余大小:"</span> + queue.remainingCapacity());<br mpa-from-tpl="t"/> }<br mpa-from-tpl="t"/>}</pre>
接着就去分析这行代码的用途，看看这一行代码，怎么就反转了 JDK 线程池的运行过程。
如果你对 JDK 线程池的源码熟悉一点的话，你大概能猜到 Tomcat 肯定是在控制新建线程的地方做了手脚，也就是下面这个地方：
<p style="text-align:center">
<img src="https://img0.tuicool.com/N7NvuaB.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
PS：需要说明一下的是，上面的截图是 JDK 线程池的 execute 方法。因为 Tomcat 线程池的提交也是复用的这个方法。但是 workQueue 不是同一个队列。
<p style="text-align:center">
<img src="https://img2.tuicool.com/vERBviI.jpg!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
那你先把工作流程和各个参数都摸熟了，然后写个 Demo ，接着去疯狂的 Debug 吧。然后你总会找到这个地方的，而且你会发现，不难找。
好了，上面主要关注我圈起来的部分。
在截图的 1371 行，如果没有把任务成功放到队列里面（前提是线程池是运行状态），则会执行 1378 行的逻辑，而这个逻辑，就是创建非核心线程的逻辑。
所以，我们重点关注一下该方法：
<pre class="prettyprint">org.apache.tomcat.util.threads.TaskQueue#offer</pre>
<img src="https://img0.tuicool.com/7jY322b.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
为了更加直观的看出来其运行流畅，我在第 80 行打了个断点运行程序如下：
<p style="text-align:center">
<img src="https://img0.tuicool.com/ZrmAZfF.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<h4>可以看到里面的几个参数，下面的讲解会用到这里面的参数：</h4>
<p style="text-align:center">
<img src="https://img1.tuicool.com/FRz2I3f.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
第一个 if 判断
首先第一个 if，判断 parent 是否为空：
<p style="text-align:center">
<img src="https://img1.tuicool.com/3IJbY3Y.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
从断点运行参数截图可以看出，这里的 parent 就是 Tomcat 的 ThreadPoolExecutor 类。
当 parent 为 null 时，直接调用原始的 offer 方法。
所以，还记得我前面说的吗？
<p style="text-align:center">
<img src="https://img2.tuicool.com/jAveaem.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
现在你知道为什么了吧？
源码，就是这个源码。道理，就是这么个道理。
第二个 if 判断
其中 getPoolSize 方法是获取线程池中当前运行的线程数量：
<p style="text-align:center">
<img src="https://img0.tuicool.com/2yqqyyz.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
第三个 if 判断
首先我们看看 getSubmittedCount 获取的是个什么玩意：
<p style="text-align:center">
<img src="https://img2.tuicool.com/U3eiqa6.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<h4>getSubmittedCount 获取的是当前已经提交但是还未完成的任务的数量，其值是队列中的数量加上正在运行的任务的数量。</h4>
<span>从断点运行参数</span>
<span>截图可以看到，</span>
而 parent.getPoolSize() 为 5。
<span>不满足条件，进入下</span>
<span>一个</span>
<span>if 判断。</span>
但是这个地方需要多说一句的是，如果当已经提交但是还未完成的任务的数量小于线程池中运行线程的数量时，Tomcat 的做法是把任务放到队列里面去，而不是立即执行。
其实这样想来也是很符合逻辑且简单的做法的。
反正有空闲的线程嘛，扔到队列里面去就被空闲的线程消费了。又何必立即执行呢？破坏流程不说，还需要额外实现。
出力不讨好。没必要。
第四个 if 判断
这个判断就很关键了。
如果当前运行中的线程数量小于最大线程数，返回 false。
注意哦，前面的几个 if 判断都是不满足条件就放入队列哦。而这里是不满足条件，就返回 false。
返回 false 意味着什么？
<img src="https://img0.tuicool.com/N7NvuaB.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
意味着要执行 1378 行代码，去创建线程了呀。
所以，整个流程图大概就是这样：
<p style="text-align:center">
<img src="https://img0.tuicool.com/jEfyYv6.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
拒绝策略需要看这个方法：
<pre class="prettyprint">org.apache.tomcat.util.threads.ThreadPoolExecutor#execute(java.lang.Runnable, long, java.util.concurrent.TimeUnit)</pre>
看一下该方法上的注释：
<p style="text-align:center">
<img src="https://img2.tuicool.com/i22Q3qf.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<h4>
如果再次放入队列的时候还是满的，则抛出拒绝异常。
这个逻辑就类似于你去上厕所，发现坑位全都被人占着。这个时候你的身体告诉你，你括弧肌最多还能在忍一分钟。于是，你掐着表在门口，深呼吸，闭眼冥想，等了一分钟。 运气好的，再去一看：哎，有个空的坑位了，赶紧占着。 运气不好，再去一看：哎，还是没有位置，怎么办呢？抛异常吧。具体怎么抛就不说了，自行想象。
所以我们看看这个地方,Tomcat 的代码是怎么实现的：
关键的逻辑就在这个 if 判断里面了。 可以看到 172 行：
if (!queue.force(command, timeout, unit))调用了队列的 force 方法。我们知道 BlockingQueue 是没有 force 方法的。 所以这个force 是 Tomcat 自定义队列特有的方法：
public boolean force(Runnable o, long timeout, TimeUnit unit) throws InterruptedException {进去一看发现：害，也不过如此嘛。就是对原生 offer 方法的一层包装而已。
if (parent == null || parent.isShutdown())
throw new RejectedExecutionException(sm.getString("taskQueue.notRunning"));
//forces the item onto the queue, to be used if the task is rejected
return super.offer(o,timeout,unit);
}
如果成功加入队列则万事大吉，啥事没有。
如果没有成功加入队列，则抛出异常，并维护 submittedCount 参数。
<img src="https://img1.tuicool.com/Unuqyqi.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
前面说过：submittedCount 参数 = 队列中的任务个数 + 正在运行的任务数。
所以，这里需要进行减一操作。
拒绝策略就说完了。
但是这个地方的源码是我带你找到的。如果你想自己找到应该怎么操作呢？
你想啊，你是想测试拒绝策略。那只要触发其拒绝策略就行了。
比如下面这样：
<p style="text-align:center">
<img src="https://img1.tuicool.com/NRjaiyA.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
给一个只能容纳 450 个任务的线程池提交 500 个任务。
然后就会抛出这个异常：
<p style="text-align:center">
<img src="https://img1.tuicool.com/EzMvM3N.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
就会找到 Tomcat 线程池的 174 行：
<p style="text-align:center">
<img src="https://img1.tuicool.com/FrEr2er.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
然后你打上一个断点，玩去吧。
那我们刚刚说的，可以在门口等一分钟再进坑是怎么回事呢？
我们把参数告诉线程池就可以了，比如下面这样：
<p style="text-align:center">
<img src="https://img2.tuicool.com/yyeYBbn.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
然后再去运行，因为队列满了后，触发拒绝异常，然后等 3 秒再去提交任务。而我们提交的一个任务 2 秒就能被执行完。
所以，这个场景下，所有的任务都会被正常执行。
<h4>现在你知道为了把你给它的任务尽量快速、全部的执行完成，Tomcat有多努力了吗？</h4>
<p style="text-align:center">
<img src="https://img0.tuicool.com/jyyeyqQ.gif" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
在看 Tomcat 自定义队列的时候我发现了作者这样的注释：
<p style="text-align:center">
<img src="https://img1.tuicool.com/rUbIJvA.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
这个地方作用是把 forcedRemainingCapacity 参数设置为 0。
这个参数是在什么时候设置的呢？
就是下面这个关闭方法的时候：
<pre class="prettyprint">org.apache.tomcat.util.threads.ThreadPoolExecutor#contextStopping</pre>
<p style="text-align:center">
<img src="https://img1.tuicool.com/UZNzuuU.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
可以看到，调用 setCorePoolSize 方法之前，作者直接把 forcedRemainingCapacity 参数设置为了 0。
注释上面写的原因是JDK ThreadPoolExecutor.setCorePoolSize 方法会去检查 remainingCapacity 是否为 0。
so，他 fake 了 condition。
<p style="text-align:center">
<img src="https://img0.tuicool.com/7vM3IvE.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
总之就是他说他也不明白为什么JDK 线程池 setCorePoolSize 方法调小核心线程池的时候要的限制队列剩余长度为 0 ，反正这样写就对了。
别问，问就是规定。
于是我去看了 JDK 线程池的 setCorePoolSize 方法，发现这个限制是在 jdk 1.6 里有，1.6 之后的版本对线程池进行了大规模的重构，取消了这个限制：
<p style="text-align:center">
<img src="https://img2.tuicool.com/YreArei.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
那 Tomcat 直接设置为 0 会带来什么问题呢？
正常的逻辑是队列剩余大小 = 队列长度 - 队列里排队的任务数。
<p style="text-align:center">
<img src="https://img1.tuicool.com/7BNr2a2.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
而当你对其线程池（队列长度为300）进行监控的时候正常情况应该是这样：
<p style="text-align:center">
<img src="https://img0.tuicool.com/NbmmMfF.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
但是当你调用 contextStopping 方法后可能会出现这样的问题：
<p style="text-align:center">
<img src="https://img2.tuicool.com/meAzA36.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
很明显不符合上面的算法了。
好了，如果你们以后需要对 Tomcat 的线程池进行监控，且 JDK 版本在 1.6版本以上。那你可以去掉这个限制，以免误报警。
好了，恭喜你，朋友。又学到了一个基本用不上的知识点，奇怪的知识又增加了一点点。
<p style="text-align:center">
<img src="https://img0.tuicool.com/q26zAr3.jpg!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
这里再扩展一个 Dubbo 的线程池实现。
<p style="text-align:center">
<img src="https://img0.tuicool.com/uuU7NjY.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<pre class="prettyprint">org.apache.dubbo.common.threadpool.support.eager.EagerThreadPoolExecutor</pre>
你可以看一下，思想还是这个思想：
<p style="text-align:center">
<img src="https://img1.tuicool.com/b6R3maU.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
但是 execute 方法有点不一样：
<p style="text-align:center">
<img src="https://img1.tuicool.com/Jb2aUre.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
从代码上看，这里放入失败之后又立马调了一次 offer 方法，且没有等待时间。
也就是说两次 offer 的间隔是非常的短的。
其实我不太明白为什么这样去写，可能是作者留着口子好扩展吧？
因为如果这样写，为什么不直接调用这个方法呢？
<pre class="prettyprint">java.util.concurrent.LinkedBlockingQueue#offer(E)</pre>
也是作者是想在极短的时间能赌一下吧？谁知道呢？
然后可以发现该线程池在拒绝策略上也做了很大的文章：
<p style="text-align:center">
<img src="https://img0.tuicool.com/eauiui2.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
可以看到日志打印的非常详尽，warn 级别：
<p style="text-align:center">
<img src="https://img1.tuicool.com/A7363eu.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
dumpJStack 方法，看名字也知道它是要去 Dump 线程了，保留现场：
<p style="text-align:center">
<img src="https://img2.tuicool.com/nUNjAv6.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
在这个方法里面，他用了 JDK 默认的线程池，去异常 Dump 线程。
<h4>等等，阿里开发规范不是说了不建议用默认线程池吗？</h4>
其实这个规范看你怎么去拿捏。在这个场景下，用自带的线程池就能满足需求了。
而且你看第二个红框：提交之后就执行了 shutdown 方法，上面还给了个贴心警告。
必须要 shutdown 线程池，不然会导致 OOM。
<h4>这就是细节呀，朋友们。魔鬼都在细节里！</h4>
这里为什么用的 shutdown 不是 shutdownNow ？他们的区别是什么？为什么不调用 shutdown 方法会 OOM？
<h4>知识点呀，朋友们，都是知识点啊！</h4>
<p style="text-align:center">
<img src="https://img2.tuicool.com/NFJbEbA.jpg!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
好了，到这里本文的分享也到了尾声。
以后当面试官问你 JDK 线程池的运行流程的时候，你答完之后画风一转，再来一个：
<h4>其实我们也可以先把最大线程数用完，然后再让任务进入队列。通过自定义队列，重写其 offer 方法就可以实现。目前我知道的 Tomcat 和 Dubbo 都提供了这样策略的线程池。</h4>
轻描淡写之间又装了一个漂亮逼。让面试官能进入下一个知识点，让你能更多的展现自己。
<p style="text-align:center">
<img src="https://img0.tuicool.com/ba2mMnv.jpg!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
本文主要介绍了 Tomcat 线程池的运行流程，和 JDK 线程池的流程比起来，它确实不一样。
而 Tomcat 线程池为什么要这样做呢？
其实就是因为 Tomcat 处理的多是 IO 密集型任务，用户在前面等着响应呢，结果你明明还能处理，却让用户的请求入队等待？
这样不好，不好。
说到底，又回到了任务类型是 IO 密集型还是 CPU 密集型这个话题上来。
好了，看到这里了，点个“在看”吧，周更很累的，不要白嫖我，需要一点正反馈。
<p style="text-align:center">
<img src="https://img1.tuicool.com/VnYfqif.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
接下来这句话以前都是这样写的：
<p style="text-align:center">
<img src="https://img1.tuicool.com/JjqmEzI.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
我是why技术，一个不是大佬，但是喜欢分享，又暖又有料的四川程序猿，成都好男人。
哦，对了。
<h4>在[why不止技术]这个号后台发送关键字[开发手册]可以获得《阿里巴巴Java开发手册-泰山版》PDF一份，最新版哦。赶快去获取吧。</h4>
<a target="_blank" href="http://mp.weixin.qq.com/s?__biz=MzIwMDI2OTY1Ng==&mid=2454166394&idx=1&sn=b19c63b34bd248861be529ee03725afb&chksm=814cf14db63b785b96772a86141d5bc8e1c84f8dfeb5f8abb1d5fab715ea7d32074f9f4b2211&scene=21#wechat_redirect" tab="innerlink" rel="nofollow,noindex">凡是过往，皆为序章。</a>
<a target="_blank" href="http://mp.weixin.qq.com/s?__biz=MzIwMDI2OTY1Ng==&mid=2454166474&idx=1&sn=91590526e8b83914f462fb3258b58c9e&chksm=814cf1fdb63b78eb127acecf18e9f69876425cc273fd56bd8912166c61e2afe7111b8382f696&scene=21#wechat_redirect" tab="innerlink" rel="nofollow,noindex">《Java并发编程的艺术》这本书有个地方写错了</a>
<a target="_blank" href="http://mp.weixin.qq.com/s?__biz=MzIwMDI2OTY1Ng==&mid=2454166417&idx=1&sn=e012669cb11a6811f94607db0882a3c7&chksm=814cf1a6b63b78b064c84acb96960bf3c483650a6d2f16dca7e37c29ba6f390762fe4e20c1e1&scene=21#wechat_redirect" tab="innerlink" rel="nofollow,noindex">有的线程它死了，于是它变成一道面试题</a>
<a target="_blank" href="http://mp.weixin.qq.com/s?__biz=MzIwMDI2OTY1Ng==&mid=2454166434&idx=1&sn=acba42a2f2f9f644a738630b8f515c4e&chksm=814cf195b63b7883b57897291a52c8ceffc1ed9067ecea77ac97cf2b209ad32d89118a3a3f15&scene=21#wechat_redirect" tab="innerlink" rel="nofollow,noindex">面试了15位来自985/211高校的2020届研究生之后，思考许久，熬夜赶出了这篇文章。</a>
<a target="_blank" href="http://mp.weixin.qq.com/s?__biz=MzIwMDI2OTY1Ng==&mid=2454166384&idx=1&sn=b8bf275a6033f0555c72dada24a5cb9a&chksm=814cf147b63b7851b10500f4f75f85da648f9d2fce9dd28b0c8fa73117276ee910d70d11f813&scene=21#wechat_redirect" tab="innerlink" rel="nofollow,noindex">普通二本，毕业三年，北漂之后，我是怎么成为程序猿的。</a>
<p style="text-align:center">
<img src="https://img2.tuicool.com/iYzQJ3m.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
</p>
<div>
<h4>有读者叫我把这个放在赞赏之后，结果放不了。</h4>
<h4>但我还是非常感动，感谢读者提出的各种建议。</h4>
<span>点亮"在看"，别白嫖我，好</span>
<span>吗？</span>
</div>
</div>
<img src="https://img1.tuicool.com/Unuqyqi.png!web" class="alignCenter" referrerpolicy="no-referrer"/>
