Tomcat中常见线程说明

柔情只为你懂 2024-04-17 06:05 39阅读 0赞

本文讲述了Tomcat的常见线程的功能、名称、线程池和配置等信息，其中源码来自于Tomcat 6.0.18。

# Work线程 #

## 功能 ##

HTTP请求的处理线程(非NIO)。当有新的http请求进来后，则会从线程池中获得一个线程Work对象，调用Work.assign函数，将新到的http请求分配给这个线程。

## 名称 ##

名称是http-\[IpAddr\]-\[Port\]-\[Number\]，如http-0.0.0.0-8080-1

这个可以从Http11Protocol中的setName函数和Worker中的start方法得知这个命名方式。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;"> <p>本文讲述了Tomcat的常见线程的功能、名称、线程池和配置等信息，其中源码来自于Tomcat 6.0.18。</p> <p>&nbsp;</p> <h1>Work线程</h1> <p>&nbsp;</p> <h2>功能</h2> <p>HTTP请求的处理线程(非NIO)。当有新的http请求进来后，则会从线程池中获得一个线程Work对象，调用Work.assign函数，将新到的http请求分配给这个线程。</p> <h2>名称</h2> <p>名称是http-[IpAddr]-[Port]-[Number]，如http-0.0.0.0-8080-1</p> <p>这个可以从Http11Protocol中的setName函数和Worker中的start方法得知这个命名方式。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td><strong>public</strong>&nbsp;<strong>String</strong>&nbsp;getName()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;<strong>String</strong>&nbsp;encodedAddr&nbsp;=&nbsp;"";</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(getAddress()&nbsp;!=&nbsp;<strong>null</strong>)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;encodedAddr&nbsp;=&nbsp;""&nbsp;+&nbsp;getAddress();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(encodedAddr.startsWith("/"&nbsp;))</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;encodedAddr&nbsp;=&nbsp;encodedAddr.substring(<strong>1</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;encodedAddr&nbsp;=&nbsp;URLEncoder.&nbsp;encode(encodedAddr)&nbsp;+&nbsp;"-";</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;("http-"&nbsp;+&nbsp;encodedAddr&nbsp;+&nbsp;endpoint.getPort());</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
     </tbody> 
    </table><h2><a rel="nofollow"></a>线程类：JIoEndpoint.Work</h2> <p>在JIoEndpoint.Work的run方法中调用await方法等待并获得下一个socket，传给handle进行处理。在await方法中，如果没有分配新的客户端请求socket， available变量会一直false，并会循环调用wait方法阻塞自己，同时释放Work对象的锁，直到Acceptor线程获得新的socket， 并调用Work.assign方法分配给该工作线程。 这时availble变量才为设置为true，并且await方法会返回分配的socket对象。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;<strong>class</strong>&nbsp;Worker&nbsp;<strong>implements</strong>&nbsp;Runnable&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;Thread&nbsp;thread&nbsp;=&nbsp;<strong>null</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;boolean&nbsp;available&nbsp;=&nbsp;<strong>false</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;Socket&nbsp;socket&nbsp;=&nbsp;<strong>null</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;Process&nbsp;an&nbsp;incoming&nbsp;TCP/IP&nbsp;connection&nbsp;on&nbsp;the&nbsp;specified&nbsp;socket.&nbsp;&nbsp;Any</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;exception&nbsp;that&nbsp;occurs&nbsp;during&nbsp;processing&nbsp;must&nbsp;be&nbsp;logged&nbsp;and&nbsp;swallowed.</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;&lt;b&gt;NOTE&lt;/b&gt;&nbsp;:&nbsp;&nbsp;This&nbsp;method&nbsp;is&nbsp;called&nbsp;from&nbsp;our&nbsp;Connector's&nbsp;thread.&nbsp;&nbsp;We</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;must&nbsp;assign&nbsp;it&nbsp;to&nbsp;our&nbsp;own&nbsp;thread&nbsp;so&nbsp;that&nbsp;multiple&nbsp;simultaneous</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;requests&nbsp;can&nbsp;be&nbsp;handled.</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;@param&nbsp;socket&nbsp;TCP&nbsp;socket&nbsp;to&nbsp;process</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>&nbsp;<strong>void</strong>&nbsp;assign(Socket&nbsp;socket&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Wait&nbsp;for&nbsp;the&nbsp;Processor&nbsp;to&nbsp;get&nbsp;the&nbsp;previous&nbsp;Socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(available&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;wait();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(InterruptedException&nbsp;e)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">42&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">43&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Store&nbsp;the&nbsp;newly&nbsp;available&nbsp;Socket&nbsp;and&nbsp;notify&nbsp;our&nbsp;thread</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">44&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">45&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.socket&nbsp;=&nbsp;socket&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">46&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">47&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;available&nbsp;=&nbsp;<strong>true</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">48&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">49&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;notifyAll();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">50&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">51&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">52&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">53&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">54&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">55&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;等待新分配的Socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">56&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">57&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">58&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">59&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>private</strong>&nbsp;<strong>synchronized</strong>&nbsp;Socket&nbsp;await()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">60&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">61&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//等待Connector提供新的Socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">62&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">63&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(!available&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">64&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">65&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">66&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">67&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;wait();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">68&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">69&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(InterruptedException&nbsp;e)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">70&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">71&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">72&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">73&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">74&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">75&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//通知Connector我们已经接收到这个Socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">76&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">77&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Socket&nbsp;socket&nbsp;=&nbsp;<strong>this</strong>.socket&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">78&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">79&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;available&nbsp;=&nbsp;<strong>false</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">80&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">81&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;notifyAll();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">82&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">83&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(socket);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">84&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">85&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">86&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">87&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">88&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">89&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;后台线程，监听进入的TCP/IP连接，并传递给合适的处理模块</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">90&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">91&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">92&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">93&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;run()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">94&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">95&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Process&nbsp;requests&nbsp;until&nbsp;we&nbsp;receive&nbsp;a&nbsp;shutdown&nbsp;signal</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">96&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">97&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//处理请求直到我们接收到shutdown信号</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">98&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">99&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(running&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">100&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">101&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//等待下一个分配的socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">102&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">103&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Socket&nbsp;socket&nbsp;=&nbsp;await();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">104&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">105&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(socket&nbsp;==&nbsp;<strong>null</strong>)</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">106&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">107&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>continue</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">108&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">109&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//设置socket的选项，并处理socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">110&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">111&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!setSocketOptions(socket)&nbsp;||&nbsp;!handler.process(socket))&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">112&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">113&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;关闭socket</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">114&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">115&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">116&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">117&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;socket.close();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">118&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">119&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(IOException&nbsp;e)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">120&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">121&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">122&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">123&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">124&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">125&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Finish&nbsp;up&nbsp;this&nbsp;request</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">126&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">127&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;socket&nbsp;=&nbsp;<strong>null</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">128&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">129&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//回收线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">130&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">131&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;recycleWorkerThread(&nbsp;<strong>this</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">132&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">133&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">134&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">135&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">136&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">137&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">138&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">139&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;开启后台处理线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">140&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">141&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">142&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">143&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;start()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">144&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">145&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread&nbsp;=&nbsp;new&nbsp;Thread(<strong>this</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">146&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">147&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread.setName(getName()&nbsp;+&nbsp;"-"&nbsp;+&nbsp;(++curThreads));</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">148&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">149&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread.setDaemon(<strong>true</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">150&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">151&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread.start();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">152&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">153&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">154&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">155&nbsp;</td> 
       <td>}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">156&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">157&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
     </tbody> 
    </table><h2><a rel="nofollow"></a>所属线程池</h2> <p>所属线程池实现功能比较简单，是内嵌到JIoEndpoint类中的实现。基本数据结构是一个工作线程栈JIoEndpoint.WorkerStack。</p> <h3><a rel="nofollow"></a>线程池主要属性</h3> <p>curThreadsBusy：当前繁忙线程数</p> <p>curThreads:当前工作线程数</p> <p>maxThreads:最大工作线程数</p> <h3><a rel="nofollow"></a>线程池启动</h3> <p>这个线程池实现功能比较简单，不需要太多启动功能。可以从JIoEndpoint类的start方法看到，启动初始化需要做的事是分配线程栈worker空间。</p> <h3><a rel="nofollow"></a>任务分配时序图</h3> <p><a href="https://img-blog.csdn.net/20141207131214760" rel="nofollow"><img alt="1" height="526" src="https://img-blog.csdn.net/20141207131212671" width="637"></a></p> <h3><a rel="nofollow"></a>任务分配</h3> <p>通过JIoEndPoint中createWorkerThread方法获得一个工作线程。如在工作线程栈workers中获得一个线程对象，如果线程栈已经是空的，并且当前线程数量curThreads还小于最大线程数maxThreads，那么就创建一个新的工作线程。然后调用Work.assign方法分配给工作线程。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;Worker&nbsp;createWorkerThread()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//获得工作线程栈workers的锁</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>&nbsp;(workers&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果工作线程栈里有线程则返回栈顶工作线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(workers&nbsp;.size()&nbsp;&gt;&nbsp;<strong>0</strong>)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy++;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;workers&nbsp;.pop();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果工作线程栈里没有线程，maxThreads大于0且当前线程数小于最大线程数，则创建一个新的线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;((maxThreads&nbsp;&gt;&nbsp;<strong>0</strong>)&nbsp;&amp;&amp;&nbsp;(curThreads&nbsp;&lt;&nbsp;maxThreads))&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy++;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(newWorkerThread());</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果maxThreads小于0，则说明没有限制，创建新的线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(maxThreads&nbsp;&lt;&nbsp;<strong>0</strong>)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy++;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(newWorkerThread());</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(<strong>null</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">42&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">43&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">44&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">45&nbsp;</td> 
       <td>}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">46&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">47&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
     </tbody> 
    </table><h3><a rel="nofollow"></a>工作线程回收</h3> <p>JIoEndPoint中recycleWorkerThread方法是回收工作线程，当http请求处理完成，则调用该方法回收工作线程。该方法首先获得worker对象锁，然后调用workers.push方法将工作线程压入工作线程栈中，接着将当前繁忙线程数减1，最后调用workers.notify方法。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;<strong>void</strong>&nbsp;recycleWorkerThread(Worker&nbsp;workerThread)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>&nbsp;(workers&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;workers.push(workerThread);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy--;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;workers.notify();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;</p> <h3><a rel="nofollow"></a>配置</h3> <p>在Tomcat中配置文件Server.xml中的Connector属性配置最大线程数maxThreads。</p> <p>例如：</p> <p>&lt;Connector port="8080"</p> <p>maxThreads="150"</p> <p>……/&gt;</p> <p>&nbsp;</p> <h1><a rel="nofollow"></a>Acceptor线程</h1> <p>&nbsp;</p> <h2><a rel="nofollow"></a>功能</h2> <p>获得HTTP请求socket。并从工作线程池中获得一个线程，将socket分配给一个工作线程。</p> <h2><a rel="nofollow"></a>名称</h2> <p>http-[IPAddr]-[Port]-Acceptor-[Number]，如http-0.0.0.0-8080-Acceptor-1</p> <h2><a rel="nofollow"></a>线程类：JIoEndpoint.Acceptor</h2> <p>&nbsp;</p> <h2><a rel="nofollow"></a>所属线程池</h2> <p>无</p> <h2><a rel="nofollow"></a>启动时序图</h2> <p>在启动时会开启Accepter线程，时序图如下：</p> <p><a href="https://img-blog.csdn.net/20141207131714421" rel="nofollow"><img alt="2" height="273" src="https://img-blog.csdn.net/20141207131714889" width="821"></a></p> <h2><a rel="nofollow"></a>线程启动</h2> <p>如上时序图，在Tomcat启动过程会调用JIoEndpoint类的start方法，会创建并启动acceptorThreadCount个Acceptor线程。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td><strong>public</strong>&nbsp;<strong>void</strong>&nbsp;start()&nbsp;throws&nbsp;Exception&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Initialize&nbsp;socket&nbsp;if&nbsp;not&nbsp;done&nbsp;before</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!initialized&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;init();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!running&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;running&nbsp;=&nbsp;<strong>true</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;paused&nbsp;=&nbsp;<strong>false</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果没有配置executor线程池，则创建工作线程栈worker,&nbsp;就是上例中的线程池的工作线程栈。</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(executor&nbsp;==&nbsp;<strong>null</strong>)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;workers&nbsp;=&nbsp;new&nbsp;WorkerStack(maxThreads);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//启动acceptor线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>&nbsp;(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;<strong>0</strong>;&nbsp;i&nbsp;&lt;&nbsp;acceptorThreadCount;&nbsp;i++)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread&nbsp;acceptorThread&nbsp;=&nbsp;new&nbsp;Thread(new&nbsp;Acceptor(),&nbsp;getName()&nbsp;+&nbsp;"-Acceptor-"&nbsp;+&nbsp;i);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptorThread.setPriority(&nbsp;threadPriority);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptorThread.setDaemon(&nbsp;daemon);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptorThread.start();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><h2><a rel="nofollow"></a>属性</h2> <p>acceptorThreadCount:开启的acceptor线程数，从源码看到这个值并没有通过配置设置，而是固定的值为1</p> <h2><a rel="nofollow"></a>配置</h2> <p>无</p> <p>&nbsp;</p> <h1><a rel="nofollow"></a>Main主线程</h1> <p>&nbsp;</p> <h2><a rel="nofollow"></a>功能</h2> <p>完成装配、初始化和启动，之后会开启SocketServer，并循环等待命令，如shutdown。</p> <h2><a rel="nofollow"></a>名称：Main</h2> <p>&nbsp;</p> <h2><a rel="nofollow"></a>线程类：Main主线程</h2> <p>&nbsp;</p> <h2><a rel="nofollow"></a>所属线程池：</h2> <p>无</p> <p>&nbsp;</p> <h1><a rel="nofollow"></a>catalina-exec线程</h1> <p>&nbsp;</p> <h2><a rel="nofollow"></a>功能</h2> <p>StandardThreadExecutor的工作线程，功能和Work线程类似。如果为Connector配置了Executor，则会使用该线程处理http请求。</p> <p>线程类：ThreadPoolExecutor.Work</p> <h2><a rel="nofollow"></a>所属线程池:StandardThreadExecutor</h2> <p>类名是org.apache.catalina.core.StandardThreadExecutor，该线程池类通过代理设计模式对Java Concurrent包中的线程池ThreadPoolExecutor进行简单的封装。并实现了Lifecycle接口，以及增加了发送消息的功能。</p> <h2><a rel="nofollow"></a>属性</h2> <p>minSpareThreads：最小空闲线程数</p> <p>maxThreads:最大线程数</p> <p>maxIdleTime：最大空闲时间</p> <h2><a rel="nofollow"></a>配置</h2> <p>在Server.xml文件中配置Executor节点，支持如下属性，</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;"> <p>Name</p> </td> 
       <td style="vertical-align:top;"> <p>Executor的名称</p> </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;"> <p>namePrefix</p> </td> 
       <td style="vertical-align:top;"> <p>工作线程前缀</p> </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;"> <p>maxThreads</p> </td> 
       <td style="vertical-align:top;"> <p>最大线程数</p> </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;"> <p>minSpareThreads</p> </td> 
       <td style="vertical-align:top;"> <p>最小空闲线程数</p> </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;"> <p>maxIdleTime</p> </td> 
       <td style="vertical-align:top;"> <p>最大空闲时间</p> </td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;</p> <p>并在Connector节点配置executor，并指定为Executor的名称。</p> <p>例如：</p> <p>&lt;Executor name="tomcatThreadPool" namePrefix="catalina-exec-" maxThreads="150" minSpareThreads="4" maxIdleTime="200"/&gt;</p> <p>&lt;Connector Address="0.0.0.0" port="8080" protocol="HTTP/1.1"executor="tomcatThreadPool".../&gt;</p> <p>&nbsp;</p> <h1><a rel="nofollow"></a>TP-Processor线程</h1> <p>&nbsp;</p> <h2><a rel="nofollow"></a>功能</h2> <p>AJP协议中Servlet容器的处理线程</p> <h2><a rel="nofollow"></a>名称</h2> <p>TP-Processor-[Number],例如TP-Processor-1</p> <h2><a rel="nofollow"></a>线程类：ThreadPool.ControlRunnable</h2> <p>&nbsp;</p> <h2><a rel="nofollow"></a>所属线程池：org.apache.tomcat.util.threads.ThreadPool</h2> <p>该线程池还会启动一个TP-Monitor线程监控空闲线程。在TheadPool会有一个ControlRunnable数组保存线程池中的工作线程。使用该线程池需要先调用start方法，进行ControlRunnable数组初始化，minSpareThreads个空闲线程的创建，以及TP-Monitor线程的启动。</p> <h3><a rel="nofollow"></a>属性</h3> <p>maxThreads：最大线程数</p> <p>minSpareThreads：最小空闲线程数</p> <p>maxSpareThreads: 最大空闲线程数</p> <h3><a rel="nofollow"></a>线程池的启动</h3> <p>通过ThreadPool.start方法，该方法会分配线程数组pool，并打开minSpareThreads空线程。如果最大空闲线程数小于最大线程数，则启动TP-Monitor线程。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td><strong>public</strong>&nbsp;<strong>synchronized</strong>&nbsp;<strong>void</strong>&nbsp;start()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;stopThePool=<strong>false</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadCount&nbsp;&nbsp;=&nbsp;<strong>0</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy&nbsp;&nbsp;=&nbsp;<strong>0</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;adjustLimits();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;pool&nbsp;=&nbsp;new&nbsp;ControlRunnable[maxThreads];</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//启动minSpareThreads空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;openThreads(&nbsp;minSpareThreads);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//如果最大空闲线程数小于最大线程数，则启动TP-Monitor线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(maxSpareThreads&nbsp;&lt;&nbsp;maxThreads)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;monitor&nbsp;=&nbsp;new&nbsp;MonitorRunnable(<strong>this</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><h3><a rel="nofollow"></a>任务分配</h3> <p>使用ThreadPool.runIt来运行新的任务，在该方法中，会调用findControlRunnable方法来获得一个工作线程。需要注意的是调用方不需要调用额外的方法来回收线程。当ControlRunnable线程完成指定的任务会自动将线程回收到线程池中。</p> <p>findControlRunnable是ThreadPool线程池的关键方法，它提供了从线程池中获得一个工作线程，并将相应的计数调整，如 tpOpen，currentThreadsBusy。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td>/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;*&nbsp;Executes&nbsp;a&nbsp;given&nbsp;Runnable&nbsp;on&nbsp;a&nbsp;thread&nbsp;in&nbsp;the&nbsp;pool,&nbsp;block&nbsp;if&nbsp;needed.</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td><strong>public</strong>&nbsp;<strong>void</strong>&nbsp;runIt(ThreadPoolRunnable&nbsp;r)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(<strong>null</strong>&nbsp;==&nbsp;r)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>throw</strong>&nbsp;new&nbsp;NullPointerException();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//从线程池中获得一个工作线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;ControlRunnable&nbsp;c&nbsp;=&nbsp;findControlRunnable();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//运行任务</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;c.runIt(r);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td><strong>private</strong>&nbsp;ControlRunnable&nbsp;findControlRunnable()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;ControlRunnable&nbsp;c=&nbsp;<strong>null</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(&nbsp;stopThePool&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>throw</strong>&nbsp;new&nbsp;IllegalStateException();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//从线程池中获得一个空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>(<strong>this</strong>&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//当前繁忙线程和当前线程数相同，则表示所有的开启线程都是繁忙的。</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(currentThreadsBusy&nbsp;==&nbsp;currentThreadCount)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">42&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">43&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果当前线程数比最大线程数小</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">44&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">45&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(currentThreadCount&nbsp;&lt;&nbsp;maxThreads)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">46&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">47&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Not&nbsp;all&nbsp;threads&nbsp;were&nbsp;open,</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">48&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">49&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Open&nbsp;new&nbsp;threads&nbsp;up&nbsp;to&nbsp;the&nbsp;max&nbsp;number&nbsp;of&nbsp;idel&nbsp;threads</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">50&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">51&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">52&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;toOpen&nbsp;=&nbsp;currentThreadCount&nbsp;+&nbsp;minSpareThreads;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">53&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">54&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;openThreads(toOpen);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">55&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">56&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">57&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">58&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logFull(log,&nbsp;currentThreadCount,&nbsp;maxThreads&nbsp;);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">59&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">60&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//线程数已经满了，等待线程成为空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">61&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">62&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">63&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">64&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.wait();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">65&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">66&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">67&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">68&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;was&nbsp;just&nbsp;catch&nbsp;Throwable&nbsp;--&nbsp;but&nbsp;no&nbsp;other</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">69&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">70&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;exceptions&nbsp;can&nbsp;be&nbsp;thrown&nbsp;by&nbsp;wait,&nbsp;right?</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">71&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">72&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;So&nbsp;we&nbsp;catch&nbsp;and&nbsp;ignore&nbsp;this&nbsp;one,&nbsp;since</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">73&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">74&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;it'll&nbsp;never&nbsp;actually&nbsp;happen,&nbsp;since&nbsp;nowhere</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">75&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">76&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;do&nbsp;we&nbsp;say&nbsp;pool.interrupt().</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">77&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">78&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>catch</strong>(InterruptedException&nbsp;e)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">79&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">80&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.error("Unexpected&nbsp;exception"&nbsp;,&nbsp;e);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">81&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">82&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">83&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">84&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(&nbsp;log&nbsp;.isDebugEnabled()&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">85&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">86&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.debug("Finished&nbsp;waiting:&nbsp;CTC="&nbsp;+currentThreadCount&nbsp;+</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">87&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">88&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;",&nbsp;CTB="&nbsp;+&nbsp;currentThreadsBusy&nbsp;);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">89&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">90&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">91&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">92&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Pool&nbsp;was&nbsp;stopped.&nbsp;Get&nbsp;away&nbsp;of&nbsp;the&nbsp;pool.</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">93&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">94&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(&nbsp;stopThePool&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">95&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">96&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>break</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">97&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">98&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">99&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">100&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">101&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">102&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">103&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">104&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//线程池已经关闭，离开线程池</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">105&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">106&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(<strong>0</strong>&nbsp;==&nbsp;currentThreadCount&nbsp;||&nbsp;stopThePool)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">107&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">108&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>throw</strong>&nbsp;new&nbsp;IllegalStateException();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">109&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">110&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">111&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">112&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//到了这里，表示有空闲线程可用</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">113&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">114&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//取出数组pool中最后一个线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">115&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">116&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;pos&nbsp;=&nbsp;currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">117&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">118&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c&nbsp;=&nbsp;pool[pos];</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">119&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">120&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pool[pos]&nbsp;=&nbsp;<strong>null</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">121&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">122&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//繁忙线程数加1</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">123&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">124&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy++;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">125&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">126&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">127&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">128&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;c;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">129&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">130&nbsp;</td> 
       <td>}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">131&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">132&nbsp;</td> 
       <td>/**&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">133&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">134&nbsp;</td> 
       <td>&nbsp;*开启线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">135&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">136&nbsp;</td> 
       <td>&nbsp;*&nbsp;@param&nbsp;toOpen&nbsp;我们将要开启的线程数</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">137&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">138&nbsp;</td> 
       <td>&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">139&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">140&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;<strong>void</strong>&nbsp;openThreads(<strong>int</strong>&nbsp;toOpen)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">141&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">142&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(toOpen&nbsp;&gt;&nbsp;maxThreads&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">143&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">144&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;toOpen&nbsp;=&nbsp;maxThreads;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">145&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">146&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">147&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">148&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//创建空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">149&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">150&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;currentThreadCount&nbsp;;&nbsp;i&nbsp;&lt;&nbsp;toOpen&nbsp;;&nbsp;i++)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">151&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">152&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//需要减去currentThreadsBusy,&nbsp;因为繁忙线程已经从pool数组中移出</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">153&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">154&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pool[i&nbsp;-&nbsp;currentThreadsBusy&nbsp;]&nbsp;=&nbsp;new&nbsp;ControlRunnable(&nbsp;<strong>this</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">155&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">156&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">157&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">158&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadCount&nbsp;=&nbsp;toOpen;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">159&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">160&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;</p> <h3><a rel="nofollow"></a>工作线程回收</h3> <p>通过ThreadPool.returnController方法回收线程。该方法会将繁忙线程数currentThreadsBusy减1，并将线程回收到线程数组中。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td>/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;*&nbsp;将线程返还线程池</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;<strong>synchronized</strong>&nbsp;<strong>void</strong>&nbsp;returnController&nbsp;(ControlRunnable&nbsp;c)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(<strong>0</strong>&nbsp;==&nbsp;currentThreadCount&nbsp;||&nbsp;stopThePool)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c.terminate();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;atomic</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy--;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//将线程回收到pool数组中</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;pool[currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>]&nbsp;=&nbsp;c;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//notify会唤醒在等待线程资源</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;notify();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;</p> <h3><a rel="nofollow"></a>配置</h3> <p>在Server.xml文件中配置Connector属性</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;"> <p>maxThreads</p> </td> 
       <td style="vertical-align:top;"> <p>最大线程数</p> </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;"> <p>minSpareThreads</p> </td> 
       <td style="vertical-align:top;"> <p>最小空闲线程数</p> </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;"> <p>maxSpareThreads</p> </td> 
       <td style="vertical-align:top;"> <p>最大空闲线程数</p> </td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;</p> <p>例如：</p> <p>&lt;Connector port="8009" protocol="AJP/1.3" redirectPort="8443" maxThreads="800" minSpareThreads="50" maxSpareThreads="500" /&gt;</p> <p>&nbsp;</p> <h1><a rel="nofollow"></a>TP-Monitor线程</h1> <p>&nbsp;</p> <h2><a rel="nofollow"></a>功能</h2> <p>监控ThreadPool线程池的空闲线程，回收比最大空闲线程数多出的空闲线程。</p> <h2><a rel="nofollow"></a>线程类：ThreadPool.MonitorRunnable</h2> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td>/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;*&nbsp;定期清理空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td><strong>public</strong>&nbsp;<strong>static</strong>&nbsp;<strong>class</strong>&nbsp;MonitorRunnable&nbsp;<strong>implements</strong>&nbsp;Runnable&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;ThreadPool&nbsp;p;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;Thread&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;interval&nbsp;=WORK_WAIT_TIMEOUT;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;boolean&nbsp;shouldTerminate&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;MonitorRunnable(ThreadPool&nbsp;p)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.p&nbsp;=p;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.start();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;start()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;shouldTerminate&nbsp;=&nbsp;<strong>false</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t&nbsp;=&nbsp;new&nbsp;Thread(<strong>this</strong>);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t.setDaemon(&nbsp;p.getDaemon()&nbsp;);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t.setName(&nbsp;p.getName()&nbsp;+&nbsp;"-Monitor");</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t.start();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;setInterval(<strong>int</strong>&nbsp;i&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.interval&nbsp;=i;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">42&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">43&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">44&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">45&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;run()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">46&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">47&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>(<strong>true</strong>&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">48&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">49&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">50&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">51&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Wait一段时间</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">52&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">53&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>(<strong>this</strong>&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">54&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">55&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.wait(interval&nbsp;);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">56&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">57&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">58&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">59&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Check&nbsp;if&nbsp;should&nbsp;terminate.</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">60&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">61&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;termination&nbsp;happens&nbsp;when&nbsp;the&nbsp;pool&nbsp;is&nbsp;shutting&nbsp;down.</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">62&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">63&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(shouldTerminate&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">64&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">65&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>break</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">66&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">67&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">68&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">69&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//回收空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">70&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">71&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;p.checkSpareControllers();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">72&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">73&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>(Throwable&nbsp;t)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">74&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">75&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ThreadPool.&nbsp;log.error("Unexpected&nbsp;exception"&nbsp;,&nbsp;t);</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">76&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">77&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">78&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">79&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">80&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">81&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">82&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">83&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;stop()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">84&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">85&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.terminate();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">86&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">87&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">88&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">89&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;/**&nbsp;停止monitor线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">90&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">91&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">92&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">93&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>synchronized</strong>&nbsp;<strong>void</strong>&nbsp;terminate()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">94&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">95&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;shouldTerminate&nbsp;=&nbsp;<strong>true</strong>&nbsp;;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">96&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">97&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.notify();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">98&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">99&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">100&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">101&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><p>ThreadPool.checkSpareControllers方法，用来被TP-Monitor线程调用回收工作线程。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td>/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;*&nbsp;被TP-Monitor线程用来回收线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;<strong>synchronized</strong>&nbsp;<strong>void</strong>&nbsp;checkSpareControllers()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(stopThePool&nbsp;)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//如果当前空闲线程数大于最大空闲线程数</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>((currentThreadCount&nbsp;-&nbsp;currentThreadsBusy)&nbsp;&gt;&nbsp;maxSpareThreads)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//回收比最大空闲线程数多出的空闲线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;toFree&nbsp;=&nbsp;currentThreadCount&nbsp;-</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy&nbsp;-</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;maxSpareThreads;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;<strong>0</strong>&nbsp;;&nbsp;i&nbsp;&lt;&nbsp;toFree&nbsp;;&nbsp;i++)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ControlRunnable&nbsp;c&nbsp;=&nbsp;pool[currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>];</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c.terminate();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pool[currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>]&nbsp;=&nbsp;<strong>null</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;currentThreadCount&nbsp;--;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;&nbsp;&nbsp;&nbsp;</p> <h2><a rel="nofollow"></a>所属线程池</h2> <p>ThreadPool线程池</p> <p>&nbsp;</p> <h1><a rel="nofollow"></a>ContainerBackgroundProcessor线程</h1> <p>&nbsp;</p> <h2><a rel="nofollow"></a>功能</h2> <p>容器后台线程，只有设置backgroundProcessorDelay大于0的容器才会启动ContainerBackgroundProcessor线程。该线程会调用当前容器的backgroundProcess方法，并且递归调用 backgroundProcessorDelay值小于等于0的子容器的方法。</p> <p>从源码中看到只有StandardEngine设置了这个backgroundProcessorDelay值为10，所以只有StandardEngine容器启动ContainerBackgroundProcessor线程， 而其它StandardHost, StandardContext设置的值都是-1。</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td>/**</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;*&nbsp;创建一个新的StandardEngine组件，并绑定默认的基础Valve。</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td><strong>public</strong>&nbsp;StandardEngine()&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>super</strong>();</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;pipeline.setBasic(new&nbsp;StandardEngineValve());</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Set&nbsp;the&nbsp;jmvRoute&nbsp;using&nbsp;the&nbsp;system&nbsp;property&nbsp;jvmRoute&nbsp;*/</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;setJvmRoute(System.&nbsp;getProperty("jvmRoute"));</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>(Exception&nbsp;ex)&nbsp;{ </td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Engine将拥有reloading线程</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;backgroundProcessorDelay&nbsp;=&nbsp;<strong>10</strong>;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><p>&nbsp;</p> <h2><a rel="nofollow"></a>线程类：ContainerBase.ContainerBackgroundProcessor</h2> <p>&nbsp;</p> <p>&nbsp;</p> 
    <table> 
     <tbody> 
      <tr> 
       <td style="vertical-align:top;">1&nbsp;</td> 
       <td>/*&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">2&nbsp;</td> 
       <td>&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">3&nbsp;</td> 
       <td>&nbsp;*&nbsp;ContainerBase的保护线程类，调用当前容器的backgroundProcess方法，并在一个固定延时后，&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">4&nbsp;</td> 
       <td>&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">5&nbsp;</td> 
       <td>&nbsp;*&nbsp;用它的子容器的backgroundProcess方法&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">6&nbsp;</td> 
       <td>&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">7&nbsp;</td> 
       <td>&nbsp;*/&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">8&nbsp;</td> 
       <td>&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">9&nbsp;</td> 
       <td><strong>protected</strong>&nbsp;<strong>class</strong>&nbsp;ContainerBackgroundProcessor&nbsp;<strong>implements</strong>&nbsp;Runnable&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">10&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">11&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public</strong>&nbsp;<strong>void</strong>&nbsp;run()&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">12&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">13&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(!threadDone&nbsp;)&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">14&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">15&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">16&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">17&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;sleep(backgroundProcessorDelay&nbsp;*&nbsp;1000L);&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">18&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">19&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(InterruptedException&nbsp;e)&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">20&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">21&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">22&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">23&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">24&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">25&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!threadDone&nbsp;)&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">26&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">27&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//获得当前容器，作为父容器&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">28&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">29&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Container&nbsp;parent&nbsp;=&nbsp;(Container)&nbsp;getMappingObject();&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">30&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">31&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ClassLoader&nbsp;cl&nbsp;=&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">32&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">33&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;currentThread().getContextClassLoader();&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">34&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">35&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(parent.getLoader()&nbsp;!=&nbsp;<strong>null</strong>)&nbsp;{&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">36&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">37&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cl&nbsp;=&nbsp;parent.getLoader().getClassLoader();&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">38&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">39&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">40&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">41&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//处理父容器和所有的子容器&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">42&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">43&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processChildren(parent,&nbsp;cl);&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">44&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">45&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">46&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">47&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">48&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">49&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">50&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">51&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;//处理父容器和所有的子容器&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">52&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">53&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;<strong>void</strong>&nbsp;processChildren(Container&nbsp;container,&nbsp;ClassLoader&nbsp;cl)&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">54&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">55&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">56&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">57&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果父容器的loader不为null，则将当前线程的上下文类加载器contextClassLoader设置为父容器&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">58&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">59&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//的loader的类加载器&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">60&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">61&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(container.getLoader()&nbsp;!=&nbsp;<strong>null</strong>)&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">62&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">63&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;currentThread().setContextClassLoader&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">64&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">65&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(container.getLoader().getClassLoader());&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">66&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">67&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">68&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">69&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//调用父容器的backgroundProcess方法&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">70&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">71&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;container.backgroundProcess();&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">72&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">73&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(Throwable&nbsp;t)&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">74&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">75&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.error("Exception&nbsp;invoking&nbsp;periodic&nbsp;operation:&nbsp;"&nbsp;,&nbsp;t);&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">76&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">77&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>finally</strong>&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">78&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">79&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;currentThread().setContextClassLoader(cl);&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">80&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">81&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">82&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">83&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//获得父容器的所有子容器&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">84&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">85&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Container[]&nbsp;children&nbsp;=&nbsp;container.findChildren();&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">86&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">87&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>&nbsp;(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;<strong>0</strong>;&nbsp;i&nbsp;&lt;&nbsp;children.length;&nbsp;i++)&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">88&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">89&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果子容器的backgroundProcessorDelay小于等于0，则递归处理子容器&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">90&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">91&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(children[i].getBackgroundProcessorDelay()&nbsp;&lt;=&nbsp;<strong>0</strong>)&nbsp;{&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">92&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">93&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processChildren(children[i],&nbsp;cl);&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">94&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">95&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">96&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">97&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">98&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">99&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">100&nbsp;</td> 
       <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</td> 
      </tr> 
      <tr> 
       <td style="vertical-align:top;">101&nbsp;</td> 
       <td>}</td> 
      </tr> 
     </tbody> 
    </table><h2><a rel="nofollow"></a>所属线程池</h2> <p>无</p> </td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
 </tbody> 
</table>

## 线程类：JIoEndpoint.Work ##

在JIoEndpoint.Work的run方法中调用await方法等待并获得下一个socket，传给handle进行处理。在await方法中，如果没有分配新的客户端请求socket， available变量会一直false，并会循环调用wait方法阻塞自己，同时释放Work对象的锁，直到Acceptor线程获得新的socket， 并调用Work.assign方法分配给该工作线程。 这时availble变量才为设置为true，并且await方法会返回分配的socket对象。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td><strong>protected&nbsp;class</strong>&nbsp;Worker&nbsp;<strong>implements</strong>&nbsp;Runnable&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;Thread&nbsp;thread&nbsp;=&nbsp;<strong>null</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;boolean&nbsp;available&nbsp;=&nbsp;<strong>false</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected</strong>&nbsp;Socket&nbsp;socket&nbsp;=&nbsp;<strong>null</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;Process&nbsp;an&nbsp;incoming&nbsp;TCP/IP&nbsp;connection&nbsp;on&nbsp;the&nbsp;specified&nbsp;socket.&nbsp;&nbsp;Any</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;exception&nbsp;that&nbsp;occurs&nbsp;during&nbsp;processing&nbsp;must&nbsp;be&nbsp;logged&nbsp;and&nbsp;swallowed.</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;&lt;b&gt;NOTE&lt;/b&gt;&nbsp;:&nbsp;&nbsp;This&nbsp;method&nbsp;is&nbsp;called&nbsp;from&nbsp;our&nbsp;Connector's&nbsp;thread.&nbsp;&nbsp;We</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;must&nbsp;assign&nbsp;it&nbsp;to&nbsp;our&nbsp;own&nbsp;thread&nbsp;so&nbsp;that&nbsp;multiple&nbsp;simultaneous</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;requests&nbsp;can&nbsp;be&nbsp;handled.</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;@param&nbsp;socket&nbsp;TCP&nbsp;socket&nbsp;to&nbsp;process</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized&nbsp;void</strong>&nbsp;assign(Socket&nbsp;socket&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Wait&nbsp;for&nbsp;the&nbsp;Processor&nbsp;to&nbsp;get&nbsp;the&nbsp;previous&nbsp;Socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(available&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;wait();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(InterruptedException&nbsp;e)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">42&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">43&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Store&nbsp;the&nbsp;newly&nbsp;available&nbsp;Socket&nbsp;and&nbsp;notify&nbsp;our&nbsp;thread</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">44&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">45&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.socket&nbsp;=&nbsp;socket&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">46&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">47&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;available&nbsp;=&nbsp;<strong>true</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">48&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">49&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;notifyAll();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">50&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">51&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">52&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">53&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">54&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">55&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;等待新分配的Socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">56&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">57&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">58&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">59&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>private&nbsp;synchronized</strong>&nbsp;Socket&nbsp;await()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">60&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">61&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//等待Connector提供新的Socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">62&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">63&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(!available&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">64&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">65&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">66&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">67&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;wait();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">68&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">69&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(InterruptedException&nbsp;e)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">70&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">71&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">72&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">73&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">74&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">75&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//通知Connector我们已经接收到这个Socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">76&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">77&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Socket&nbsp;socket&nbsp;=&nbsp;<strong>this</strong>.socket&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">78&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">79&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;available&nbsp;=&nbsp;<strong>false</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">80&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">81&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;notifyAll();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">82&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">83&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(socket);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">84&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">85&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">86&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">87&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">88&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">89&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;后台线程，监听进入的TCP/IP连接，并传递给合适的处理模块</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">90&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">91&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">92&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">93&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;run()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">94&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">95&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Process&nbsp;requests&nbsp;until&nbsp;we&nbsp;receive&nbsp;a&nbsp;shutdown&nbsp;signal</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">96&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">97&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//处理请求直到我们接收到shutdown信号</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">98&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">99&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(running&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">100&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">101&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//等待下一个分配的socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">102&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">103&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Socket&nbsp;socket&nbsp;=&nbsp;await();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">104&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">105&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(socket&nbsp;==&nbsp;<strong>null</strong>)</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">106&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">107&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>continue</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">108&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">109&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//设置socket的选项，并处理socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">110&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">111&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!setSocketOptions(socket)&nbsp;||&nbsp;!handler.process(socket))&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">112&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">113&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;关闭socket</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">114&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">115&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">116&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">117&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;socket.close();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">118&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">119&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(IOException&nbsp;e)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">120&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">121&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">122&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">123&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">124&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">125&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Finish&nbsp;up&nbsp;this&nbsp;request</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">126&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">127&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;socket&nbsp;=&nbsp;<strong>null</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">128&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">129&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//回收线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">130&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">131&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;recycleWorkerThread(&nbsp;<strong>this</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">132&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">133&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">134&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">135&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">136&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">137&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">138&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">139&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*&nbsp;开启后台处理线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">140&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">141&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">142&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">143&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;start()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">144&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">145&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread&nbsp;=&nbsp;new&nbsp;Thread(<strong>this</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">146&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">147&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread.setName(getName()&nbsp;+&nbsp;"-"&nbsp;+&nbsp;(++curThreads));</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">148&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">149&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread.setDaemon(<strong>true</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">150&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">151&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;thread.start();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">152&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">153&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">154&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">155&nbsp;</td> 
   <td>}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">156&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">157&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
 </tbody> 
</table>

## 所属线程池 ##

所属线程池实现功能比较简单，是内嵌到JIoEndpoint类中的实现。基本[数据结构][Link 1]是一个工作线程栈JIoEndpoint.WorkerStack。

### 线程池主要属性 ###

curThreadsBusy：当前繁忙线程数

curThreads:当前工作线程数

maxThreads:最大工作线程数

### 线程池启动 ###

这个线程池实现功能比较简单，不需要太多启动功能。可以从JIoEndpoint类的start方法看到，启动初始化需要做的事是分配线程栈worker空间。

### 任务分配时序图 ###

[![1][]][1 1]

### 任务分配 ###

通过JIoEndPoint中createWorkerThread方法获得一个工作线程。如在工作线程栈workers中获得一个线程对象，如果线程栈已经是空的，并且当前线程数量curThreads还小于最大线程数maxThreads，那么就创建一个新的工作线程。然后调用Work.assign方法分配给工作线程。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td><strong>protected</strong>&nbsp;Worker&nbsp;createWorkerThread()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//获得工作线程栈workers的锁</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>&nbsp;(workers&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果工作线程栈里有线程则返回栈顶工作线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(workers&nbsp;.size()&nbsp;&gt;&nbsp;<strong>0</strong>)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy++;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;workers&nbsp;.pop();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果工作线程栈里没有线程，maxThreads大于0且当前线程数小于最大线程数，则创建一个新的线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;((maxThreads&nbsp;&gt;&nbsp;<strong>0</strong>)&nbsp;&amp;&amp;&nbsp;(curThreads&nbsp;&lt;&nbsp;maxThreads))&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy++;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(newWorkerThread());</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果maxThreads小于0，则说明没有限制，创建新的线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(maxThreads&nbsp;&lt;&nbsp;<strong>0</strong>)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy++;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(newWorkerThread());</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;(<strong>null</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">42&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">43&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">44&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">45&nbsp;</td> 
   <td>}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">46&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">47&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
 </tbody> 
</table>

### 工作线程回收 ###

JIoEndPoint中recycleWorkerThread方法是回收工作线程，当http请求处理完成，则调用该方法回收工作线程。该方法首先获得worker对象锁，然后调用workers.push方法将工作线程压入工作线程栈中，接着将当前繁忙线程数减1，最后调用workers.notify方法。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td><strong>protected&nbsp;void</strong>&nbsp;recycleWorkerThread(Worker&nbsp;workerThread)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>&nbsp;(workers&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;workers.push(workerThread);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;curThreadsBusy--;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;workers.notify();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

### 配置 ###

在Tomcat中配置文件Server.xml中的Connector属性配置最大线程数maxThreads。

例如：

<Connector port="8080"

maxThreads="150"

……/>

# Acceptor线程 #

## 功能 ##

获得HTTP请求socket。并从工作线程池中获得一个线程，将socket分配给一个工作线程。

## 名称 ##

http-\[IPAddr\]-\[Port\]-Acceptor-\[Number\]，如http-0.0.0.0-8080-Acceptor-1

## 线程类：JIoEndpoint.Acceptor ##

## 所属线程池 ##

无

## 启动时序图 ##

在启动时会开启Accepter线程，时序图如下：

[![2][]][2 1]

## 线程启动 ##

如上时序图，在Tomcat启动过程会调用JIoEndpoint类的start方法，会创建并启动acceptorThreadCount个Acceptor线程。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td><strong>public&nbsp;void</strong>&nbsp;start()&nbsp;throws&nbsp;Exception&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Initialize&nbsp;socket&nbsp;if&nbsp;not&nbsp;done&nbsp;before</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!initialized&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;init();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!running&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;running&nbsp;=&nbsp;<strong>true</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;paused&nbsp;=&nbsp;<strong>false</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果没有配置executor线程池，则创建工作线程栈worker,&nbsp;就是上例中的线程池的工作线程栈。</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(executor&nbsp;==&nbsp;<strong>null</strong>)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;workers&nbsp;=&nbsp;new&nbsp;WorkerStack(maxThreads);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//启动acceptor线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>&nbsp;(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;<strong>0</strong>;&nbsp;i&nbsp;&lt;&nbsp;acceptorThreadCount;&nbsp;i++)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread&nbsp;acceptorThread&nbsp;=&nbsp;new&nbsp;Thread(new&nbsp;Acceptor(),&nbsp;getName()&nbsp;+&nbsp;"-Acceptor-"&nbsp;+&nbsp;i);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptorThread.setPriority(&nbsp;threadPriority);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptorThread.setDaemon(&nbsp;daemon);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;acceptorThread.start();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

## 属性 ##

acceptorThreadCount:开启的acceptor线程数，从源码看到这个值并没有通过配置设置，而是固定的值为1

## 配置 ##

无

# Main主线程 #

## 功能 ##

完成装配、初始化和启动，之后会开启SocketServer，并循环等待命令，如shutdown。

## 名称：Main ##

## 线程类：Main主线程 ##

## 所属线程池： ##

无

# catalina-exec线程 #

## 功能 ##

StandardThreadExecutor的工作线程，功能和Work线程类似。如果为Connector配置了Executor，则会使用该线程处理http请求。

线程类：ThreadPoolExecutor.Work

## 所属线程池:StandardThreadExecutor ##

类名是org.apache.catalina.core.StandardThreadExecutor，该线程池类通过代理设计模式对[Java ][Java]Concurrent包中的线程池ThreadPoolExecutor进行简单的封装。并实现了Lifecycle接口，以及增加了发送消息的功能。

## 属性 ##

minSpareThreads：最小空闲线程数

maxThreads:最大线程数

maxIdleTime：最大空闲时间

## 配置 ##

在Server.xml文件中配置Executor节点，支持如下属性，

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;"> <p>Name</p> </td> 
   <td style="vertical-align:top;"> <p>Executor的名称</p> </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;"> <p>namePrefix</p> </td> 
   <td style="vertical-align:top;"> <p>工作线程前缀</p> </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;"> <p>maxThreads</p> </td> 
   <td style="vertical-align:top;"> <p>最大线程数</p> </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;"> <p>minSpareThreads</p> </td> 
   <td style="vertical-align:top;"> <p>最小空闲线程数</p> </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;"> <p>maxIdleTime</p> </td> 
   <td style="vertical-align:top;"> <p>最大空闲时间</p> </td> 
  </tr> 
 </tbody> 
</table>

并在Connector节点配置executor，并指定为Executor的名称。

例如：

# TP-Processor线程 #

## 功能 ##

AJP协议中Servlet容器的处理线程

## 名称 ##

TP-Processor-\[Number\],例如TP-Processor-1

## 线程类：ThreadPool.ControlRunnable ##

## 所属线程池：org.apache.tomcat.util.threads.ThreadPool ##

该线程池还会启动一个TP-Monitor线程监控空闲线程。在TheadPool会有一个ControlRunnable数组保存线程池中的工作线程。使用该线程池需要先调用start方法，进行ControlRunnable数组初始化，minSpareThreads个空闲线程的创建，以及TP-Monitor线程的启动。

### 属性 ###

maxThreads：最大线程数

minSpareThreads：最小空闲线程数

maxSpareThreads: 最大空闲线程数

### 线程池的启动 ###

通过ThreadPool.start方法，该方法会分配线程数组pool，并打开minSpareThreads空线程。如果最大空闲线程数小于最大线程数，则启动TP-Monitor线程。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td><strong>public&nbsp;synchronized&nbsp;void</strong>&nbsp;start()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;stopThePool=<strong>false</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadCount&nbsp;&nbsp;=&nbsp;<strong>0</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy&nbsp;&nbsp;=&nbsp;<strong>0</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;adjustLimits();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;pool&nbsp;=&nbsp;new&nbsp;ControlRunnable[maxThreads];</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//启动minSpareThreads空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;openThreads(&nbsp;minSpareThreads);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//如果最大空闲线程数小于最大线程数，则启动TP-Monitor线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(maxSpareThreads&nbsp;&lt;&nbsp;maxThreads)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;monitor&nbsp;=&nbsp;new&nbsp;MonitorRunnable(<strong>this</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

### 任务分配 ###

使用ThreadPool.runIt来运行新的任务，在该方法中，会调用findControlRunnable方法来获得一个工作线程。需要注意的是调用方不需要调用额外的方法来回收线程。当ControlRunnable线程完成指定的任务会自动将线程回收到线程池中。

findControlRunnable是ThreadPool线程池的关键方法，它提供了从线程池中获得一个工作线程，并将相应的计数调整，如 tpOpen，currentThreadsBusy。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td>/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;*&nbsp;Executes&nbsp;a&nbsp;given&nbsp;Runnable&nbsp;on&nbsp;a&nbsp;thread&nbsp;in&nbsp;the&nbsp;pool,&nbsp;block&nbsp;if&nbsp;needed.</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td><strong>public&nbsp;void</strong>&nbsp;runIt(ThreadPoolRunnable&nbsp;r)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(<strong>null</strong>&nbsp;==&nbsp;r)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>throw</strong>&nbsp;new&nbsp;NullPointerException();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//从线程池中获得一个工作线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;ControlRunnable&nbsp;c&nbsp;=&nbsp;findControlRunnable();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//运行任务</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;c.runIt(r);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td><strong>private</strong>&nbsp;ControlRunnable&nbsp;findControlRunnable()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;ControlRunnable&nbsp;c=&nbsp;<strong>null</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(&nbsp;stopThePool&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>throw</strong>&nbsp;new&nbsp;IllegalStateException();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//从线程池中获得一个空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>(<strong>this</strong>&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//当前繁忙线程和当前线程数相同，则表示所有的开启线程都是繁忙的。</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(currentThreadsBusy&nbsp;==&nbsp;currentThreadCount)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">42&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">43&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果当前线程数比最大线程数小</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">44&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">45&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(currentThreadCount&nbsp;&lt;&nbsp;maxThreads)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">46&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">47&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Not&nbsp;all&nbsp;threads&nbsp;were&nbsp;open,</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">48&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">49&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Open&nbsp;new&nbsp;threads&nbsp;up&nbsp;to&nbsp;the&nbsp;max&nbsp;number&nbsp;of&nbsp;idel&nbsp;threads</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">50&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">51&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">52&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;toOpen&nbsp;=&nbsp;currentThreadCount&nbsp;+&nbsp;minSpareThreads;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">53&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">54&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;openThreads(toOpen);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">55&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">56&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;else&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">57&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">58&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;logFull(log,&nbsp;currentThreadCount,&nbsp;maxThreads&nbsp;);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">59&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">60&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//线程数已经满了，等待线程成为空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">61&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">62&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">63&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">64&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.wait();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">65&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">66&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">67&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">68&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;was&nbsp;just&nbsp;catch&nbsp;Throwable&nbsp;--&nbsp;but&nbsp;no&nbsp;other</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">69&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">70&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;exceptions&nbsp;can&nbsp;be&nbsp;thrown&nbsp;by&nbsp;wait,&nbsp;right?</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">71&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">72&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;So&nbsp;we&nbsp;catch&nbsp;and&nbsp;ignore&nbsp;this&nbsp;one,&nbsp;since</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">73&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">74&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;it'll&nbsp;never&nbsp;actually&nbsp;happen,&nbsp;since&nbsp;nowhere</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">75&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">76&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;do&nbsp;we&nbsp;say&nbsp;pool.interrupt().</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">77&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">78&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>catch</strong>(InterruptedException&nbsp;e)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">79&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">80&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.error("Unexpected&nbsp;exception"&nbsp;,&nbsp;e);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">81&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">82&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">83&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">84&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(&nbsp;log&nbsp;.isDebugEnabled()&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">85&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">86&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.debug("Finished&nbsp;waiting:&nbsp;CTC="&nbsp;+currentThreadCount&nbsp;+</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">87&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">88&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;",&nbsp;CTB="&nbsp;+&nbsp;currentThreadsBusy&nbsp;);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">89&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">90&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">91&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">92&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Pool&nbsp;was&nbsp;stopped.&nbsp;Get&nbsp;away&nbsp;of&nbsp;the&nbsp;pool.</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">93&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">94&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(&nbsp;stopThePool&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">95&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">96&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>break</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">97&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">98&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">99&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">100&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">101&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">102&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">103&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">104&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//线程池已经关闭，离开线程池</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">105&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">106&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(<strong>0</strong>&nbsp;==&nbsp;currentThreadCount&nbsp;||&nbsp;stopThePool)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">107&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">108&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>throw</strong>&nbsp;new&nbsp;IllegalStateException();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">109&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">110&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">111&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">112&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//到了这里，表示有空闲线程可用</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">113&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">114&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//取出数组pool中最后一个线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">115&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">116&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;pos&nbsp;=&nbsp;currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">117&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">118&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c&nbsp;=&nbsp;pool[pos];</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">119&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">120&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pool[pos]&nbsp;=&nbsp;<strong>null</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">121&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">122&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//繁忙线程数加1</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">123&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">124&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy++;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">125&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">126&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">127&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">128&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>&nbsp;c;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">129&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">130&nbsp;</td> 
   <td>}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">131&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">132&nbsp;</td> 
   <td>/**&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">133&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">134&nbsp;</td> 
   <td>&nbsp;*开启线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">135&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">136&nbsp;</td> 
   <td>&nbsp;*&nbsp;@param&nbsp;toOpen&nbsp;我们将要开启的线程数</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">137&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">138&nbsp;</td> 
   <td>&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">139&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">140&nbsp;</td> 
   <td><strong>protected&nbsp;void</strong>&nbsp;openThreads(<strong>int</strong>&nbsp;toOpen)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">141&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">142&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(toOpen&nbsp;&gt;&nbsp;maxThreads&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">143&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">144&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;toOpen&nbsp;=&nbsp;maxThreads;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">145&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">146&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">147&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">148&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//创建空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">149&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">150&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;currentThreadCount&nbsp;;&nbsp;i&nbsp;&lt;&nbsp;toOpen&nbsp;;&nbsp;i++)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">151&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">152&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//需要减去currentThreadsBusy,&nbsp;因为繁忙线程已经从pool数组中移出</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">153&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">154&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pool[i&nbsp;-&nbsp;currentThreadsBusy&nbsp;]&nbsp;=&nbsp;new&nbsp;ControlRunnable(&nbsp;<strong>this</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">155&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">156&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">157&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">158&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadCount&nbsp;=&nbsp;toOpen;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">159&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">160&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

### 工作线程回收 ###

通过ThreadPool.returnController方法回收线程。该方法会将繁忙线程数currentThreadsBusy减1，并将线程回收到线程数组中。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td>/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;*&nbsp;将线程返还线程池</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td><strong>protected&nbsp;synchronized&nbsp;void</strong>&nbsp;returnController&nbsp;(ControlRunnable&nbsp;c)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(<strong>0</strong>&nbsp;==&nbsp;currentThreadCount&nbsp;||&nbsp;stopThePool)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c.terminate();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;atomic</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy--;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//将线程回收到pool数组中</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;pool[currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>]&nbsp;=&nbsp;c;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//notify会唤醒在等待线程资源</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;notify();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

### 配置 ###

在Server.xml文件中配置Connector属性

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;"> <p>maxThreads</p> </td> 
   <td style="vertical-align:top;"> <p>最大线程数</p> </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;"> <p>minSpareThreads</p> </td> 
   <td style="vertical-align:top;"> <p>最小空闲线程数</p> </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;"> <p>maxSpareThreads</p> </td> 
   <td style="vertical-align:top;"> <p>最大空闲线程数</p> </td> 
  </tr> 
 </tbody> 
</table>

例如：

# TP-Monitor线程 #

## 功能 ##

监控ThreadPool线程池的空闲线程，回收比最大空闲线程数多出的空闲线程。

## 线程类：ThreadPool.MonitorRunnable ##

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td>/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;*&nbsp;定期清理空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td><strong>public&nbsp;static&nbsp;class</strong>&nbsp;MonitorRunnable&nbsp;<strong>implements</strong>&nbsp;Runnable&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;ThreadPool&nbsp;p;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;Thread&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;interval&nbsp;=WORK_WAIT_TIMEOUT;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;boolean&nbsp;shouldTerminate&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;MonitorRunnable(ThreadPool&nbsp;p)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.p&nbsp;=p;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.start();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;start()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;shouldTerminate&nbsp;=&nbsp;<strong>false</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t&nbsp;=&nbsp;new&nbsp;Thread(<strong>this</strong>);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t.setDaemon(&nbsp;p.getDaemon()&nbsp;);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t.setName(&nbsp;p.getName()&nbsp;+&nbsp;"-Monitor");</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;t.start();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;setInterval(<strong>int</strong>&nbsp;i&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.interval&nbsp;=i;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">42&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">43&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">44&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">45&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;run()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">46&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">47&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>(<strong>true</strong>&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">48&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">49&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">50&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">51&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//Wait一段时间</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">52&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">53&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>synchronized</strong>(<strong>this</strong>&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">54&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">55&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.wait(interval&nbsp;);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">56&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">57&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">58&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">59&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Check&nbsp;if&nbsp;should&nbsp;terminate.</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">60&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">61&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;termination&nbsp;happens&nbsp;when&nbsp;the&nbsp;pool&nbsp;is&nbsp;shutting&nbsp;down.</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">62&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">63&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(shouldTerminate&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">64&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">65&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>break</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">66&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">67&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">68&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">69&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//回收空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">70&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">71&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;p.checkSpareControllers();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">72&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">73&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>(Throwable&nbsp;t)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">74&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">75&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ThreadPool.&nbsp;log.error("Unexpected&nbsp;exception"&nbsp;,&nbsp;t);</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">76&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">77&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">78&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">79&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">80&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">81&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">82&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">83&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;stop()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">84&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">85&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.terminate();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">86&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">87&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">88&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">89&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;/**&nbsp;停止monitor线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">90&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">91&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">92&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">93&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;synchronized&nbsp;void</strong>&nbsp;terminate()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">94&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">95&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;shouldTerminate&nbsp;=&nbsp;<strong>true</strong>&nbsp;;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">96&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">97&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>this</strong>.notify();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">98&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">99&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">100&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">101&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

ThreadPool.checkSpareControllers方法，用来被TP-Monitor线程调用回收工作线程。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td>/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;*&nbsp;被TP-Monitor线程用来回收线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td><strong>protected&nbsp;synchronized&nbsp;void</strong>&nbsp;checkSpareControllers()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>(stopThePool&nbsp;)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>return</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//如果当前空闲线程数大于最大空闲线程数</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>((currentThreadCount&nbsp;-&nbsp;currentThreadsBusy)&nbsp;&gt;&nbsp;maxSpareThreads)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//回收比最大空闲线程数多出的空闲线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>int</strong>&nbsp;toFree&nbsp;=&nbsp;currentThreadCount&nbsp;-</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;currentThreadsBusy&nbsp;-</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;maxSpareThreads;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;<strong>0</strong>&nbsp;;&nbsp;i&nbsp;&lt;&nbsp;toFree&nbsp;;&nbsp;i++)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ControlRunnable&nbsp;c&nbsp;=&nbsp;pool[currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>];</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;c.terminate();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pool[currentThreadCount&nbsp;-&nbsp;currentThreadsBusy&nbsp;-&nbsp;<strong>1</strong>]&nbsp;=&nbsp;<strong>null</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;currentThreadCount&nbsp;--;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

## 所属线程池 ##

ThreadPool线程池

# ContainerBackgroundProcessor线程 #

## 功能 ##

容器后台线程，只有设置backgroundProcessorDelay大于0的容器才会启动ContainerBackgroundProcessor线程。该线程会调用当前容器的backgroundProcess方法，并且递归调用 backgroundProcessorDelay值小于等于0的子容器的方法。

从源码中看到只有StandardEngine设置了这个backgroundProcessorDelay值为10，所以只有StandardEngine容器启动ContainerBackgroundProcessor线程， 而其它StandardHost, StandardContext设置的值都是-1。

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td>/**</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;*&nbsp;创建一个新的StandardEngine组件，并绑定默认的基础Valve。</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td><strong>public</strong>&nbsp;StandardEngine()&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>super</strong>();</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;pipeline.setBasic(new&nbsp;StandardEngineValve());</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;/*&nbsp;Set&nbsp;the&nbsp;jmvRoute&nbsp;using&nbsp;the&nbsp;system&nbsp;property&nbsp;jvmRoute&nbsp;*/</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;setJvmRoute(System.&nbsp;getProperty("jvmRoute"));</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>(Exception&nbsp;ex)&nbsp;{ </td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//&nbsp;Engine将拥有reloading线程</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;backgroundProcessorDelay&nbsp;=&nbsp;<strong>10</strong>;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

## 线程类：ContainerBase.ContainerBackgroundProcessor ##

<table> 
 <tbody> 
  <tr> 
   <td style="vertical-align:top;">1&nbsp;</td> 
   <td>/*&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">2&nbsp;</td> 
   <td>&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">3&nbsp;</td> 
   <td>&nbsp;*&nbsp;ContainerBase的保护线程类，调用当前容器的backgroundProcess方法，并在一个固定延时后，&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">4&nbsp;</td> 
   <td>&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">5&nbsp;</td> 
   <td>&nbsp;*&nbsp;用它的子容器的backgroundProcess方法&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">6&nbsp;</td> 
   <td>&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">7&nbsp;</td> 
   <td>&nbsp;*/&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">8&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">9&nbsp;</td> 
   <td><strong>protected&nbsp;class</strong>&nbsp;ContainerBackgroundProcessor&nbsp;<strong>implements</strong>&nbsp;Runnable&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">10&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">11&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>public&nbsp;void</strong>&nbsp;run()&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">12&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">13&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>while</strong>&nbsp;(!threadDone&nbsp;)&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">14&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">15&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">16&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">17&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;sleep(backgroundProcessorDelay&nbsp;*&nbsp;1000L);&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">18&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">19&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(InterruptedException&nbsp;e)&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">20&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">21&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;;&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">22&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">23&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">24&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">25&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(!threadDone&nbsp;)&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">26&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">27&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//获得当前容器，作为父容器&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">28&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">29&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Container&nbsp;parent&nbsp;=&nbsp;(Container)&nbsp;getMappingObject();&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">30&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">31&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ClassLoader&nbsp;cl&nbsp;=&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">32&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">33&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;currentThread().getContextClassLoader();&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">34&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">35&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(parent.getLoader()&nbsp;!=&nbsp;<strong>null</strong>)&nbsp;{&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">36&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">37&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;cl&nbsp;=&nbsp;parent.getLoader().getClassLoader();&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">38&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">39&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">40&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">41&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//处理父容器和所有的子容器&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">42&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">43&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processChildren(parent,&nbsp;cl);&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">44&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">45&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">46&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">47&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">48&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">49&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">50&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">51&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;//处理父容器和所有的子容器&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">52&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">53&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;<strong>protected&nbsp;void</strong>&nbsp;processChildren(Container&nbsp;container,&nbsp;ClassLoader&nbsp;cl)&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">54&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">55&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>try</strong>&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">56&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">57&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果父容器的loader不为null，则将当前线程的上下文类加载器contextClassLoader设置为父容器&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">58&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">59&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//的loader的类加载器&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">60&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">61&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(container.getLoader()&nbsp;!=&nbsp;<strong>null</strong>)&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">62&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">63&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;currentThread().setContextClassLoader&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">64&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">65&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;(container.getLoader().getClassLoader());&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">66&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">67&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">68&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">69&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//调用父容器的backgroundProcess方法&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">70&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">71&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;container.backgroundProcess();&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">72&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">73&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>catch</strong>&nbsp;(Throwable&nbsp;t)&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">74&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">75&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;log.error("Exception&nbsp;invoking&nbsp;periodic&nbsp;operation:&nbsp;"&nbsp;,&nbsp;t);&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">76&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">77&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;<strong>finally</strong>&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">78&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">79&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Thread.&nbsp;currentThread().setContextClassLoader(cl);&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">80&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">81&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">82&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">83&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//获得父容器的所有子容器&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">84&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">85&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;Container[]&nbsp;children&nbsp;=&nbsp;container.findChildren();&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">86&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">87&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>for</strong>&nbsp;(<strong>int</strong>&nbsp;i&nbsp;=&nbsp;<strong>0</strong>;&nbsp;i&nbsp;&lt;&nbsp;children.length;&nbsp;i++)&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">88&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">89&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;//如果子容器的backgroundProcessorDelay小于等于0，则递归处理子容器&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">90&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">91&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<strong>if</strong>&nbsp;(children[i].getBackgroundProcessorDelay()&nbsp;&lt;=&nbsp;<strong>0</strong>)&nbsp;{&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">92&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">93&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;processChildren(children[i],&nbsp;cl);&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">94&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">95&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">96&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">97&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">98&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">99&nbsp;</td> 
   <td>&nbsp;&nbsp;&nbsp;}&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">100&nbsp;</td> 
   <td>&nbsp;</td> 
  </tr> 
  <tr> 
   <td style="vertical-align:top;">101&nbsp;</td> 
   <td>}</td> 
  </tr> 
 </tbody> 
</table>

## 所属线程池 ##

无

[Link 1]: http://lib.csdn.net/base/datastructure
[1]: https://imgconvert.csdnimg.cn/aHR0cDovL2ltZy5ibG9nLmNzZG4ubmV0LzIwMTQxMjA3MTMxMjEyNjcx?x-oss-process=image/format,png
[1 1]: https://img-blog.csdn.net/20141207131214760
[2]: https://imgconvert.csdnimg.cn/aHR0cDovL2ltZy5ibG9nLmNzZG4ubmV0LzIwMTQxMjA3MTMxNzE0ODg5?x-oss-process=image/format,png
[2 1]: https://img-blog.csdn.net/20141207131714421
[Java]: http://lib.csdn.net/base/java