spring線程池ThreadPoolExecutor配置并且得到任務執行的結果

用的ThreadPoolExecutor的時候，又想知道被執行的任務的執行情況，這時就可以用FutureTask。

ThreadPoolTask

<code>01</code>

<code>package</code> <code>com.zuidaima.threadpool;</code>

<code>02</code>

<code>03</code>

<code>import</code> <code>java.io.Serializable;</code>

<code>04</code>

<code>import</code> <code>java.util.concurrent.Callable;</code>

<code>05</code>

<code>06</code>

<code>public</code> <code>class</code> <code>ThreadPoolTask </code><code>implements</code> <code>Callable&lt;String&gt;, Serializable {</code>

<code>07</code>

<code>08</code>

<code>    </code><code>private</code> <code>static</code> <code>final</code> <code>long</code> <code>serialVersionUID = </code><code>0</code><code>;</code>

<code>09</code>

<code>10</code>

<code>    </code><code>// 儲存任務所需要的資料</code>

<code>11</code>

<code>    </code><code>private</code> <code>Object threadPoolTaskData;</code>

<code>12</code>

<code>13</code>

<code>    </code><code>private</code> <code>static</code> <code>int</code> <code>consumeTaskSleepTime = </code><code>2000</code><code>;</code>

<code>14</code>

<code>15</code>

<code>    </code><code>public</code> <code>ThreadPoolTask(Object tasks) {</code>

<code>16</code>

<code>        </code><code>this</code><code>.threadPoolTaskData = tasks;</code>

<code>17</code>

<code>    </code><code>}</code>

<code>18</code>

<code>19</code>

<code>    </code><code>public</code> <code>synchronized</code> <code>String call() </code><code>throws</code> <code>Exception {</code>

<code>20</code>

<code>        </code><code>// 處理一個任務，這裡的處理方式太簡單了，僅僅是一個列印語句</code>

<code>21</code>

<code>        </code><code>System.out.println(</code><code>"開始執行任務："</code> <code>+ threadPoolTaskData);</code>

<code>22</code>

<code>        </code><code>String result = </code><code>""</code><code>;</code>

<code>23</code>

<code>        </code><code>// //便于觀察，等待一段時間</code>

<code>24</code>

<code>        </code><code>try</code> <code>{</code>

<code>25</code>

<code>            </code><code>// long r = 5/0;</code>

<code>26</code>

<code>            </code><code>for</code> <code>(</code><code>int</code> <code>i = </code><code>0</code><code>; i &lt; </code><code>100000000</code><code>; i++) {</code>

<code>27</code>

<code>28</code>

<code>            </code><code>}</code>

<code>29</code>

<code>            </code><code>result = </code><code>"OK"</code><code>;</code>

<code>30</code>

<code>        </code><code>} </code><code>catch</code> <code>(Exception e) {</code>

<code>31</code>

<code>            </code><code>e.printStackTrace();</code>

<code>32</code>

<code>            </code><code>result = </code><code>"ERROR"</code><code>;</code>

<code>33</code>

<code>        </code><code>}</code>

<code>34</code>

<code>        </code><code>threadPoolTaskData = </code><code>null</code><code>;</code>

<code>35</code>

<code>        </code><code>return</code> <code>result;</code>

<code>36</code>

<code>37</code>

<code>}</code>

模拟用戶端送出的線程

<code>import</code> <code>java.util.concurrent.ExecutionException;</code>

<code>import</code> <code>java.util.concurrent.FutureTask;</code>

<code>import</code> <code>java.util.concurrent.TimeUnit;</code>

<code>import</code> <code>org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;</code>

<code>public</code> <code>class</code> <code>StartTaskThread </code><code>implements</code> <code>Runnable {</code>

<code>    </code><code>private</code> <code>ThreadPoolTaskExecutor threadPoolTaskExecutor;</code>

<code>    </code><code>private</code> <code>int</code> <code>i;</code>

<code>    </code><code>public</code> <code>StartTaskThread(ThreadPoolTaskExecutor threadPoolTaskExecutor, </code><code>int</code> <code>i) {</code>

<code>        </code><code>this</code><code>.threadPoolTaskExecutor = threadPoolTaskExecutor;</code>

<code>        </code><code>this</code><code>.i = i;</code>

<code>    </code><code>@Override</code>

<code>    </code><code>public</code> <code>synchronized</code> <code>void</code> <code>run() {</code>

<code>        </code><code>String task = </code><code>"task@ "</code> <code>+ i;</code>

<code>        </code><code>System.out.println(</code><code>"建立任務并送出到線程池中："</code> <code>+ task);</code>

<code>        </code><code>FutureTask&lt;String&gt; futureTask = </code><code>new</code> <code>FutureTask&lt;String&gt;(</code>

<code>                </code><code>new</code> <code>ThreadPoolTask(task));</code>

<code>        </code><code>threadPoolTaskExecutor.execute(futureTask);</code>

<code>        </code><code>// 在這裡可以做别的任何事情</code>

<code>        </code><code>String result = </code><code>null</code><code>;</code>

<code>            </code><code>// 取得結果，同時設定逾時執行時間為1秒。同樣可以用future.get()，不設定執行逾時時間取得結果</code>

<code>            </code><code>result = futureTask.get(</code><code>1000</code><code>, TimeUnit.MILLISECONDS);</code>

<code>        </code><code>} </code><code>catch</code> <code>(InterruptedException e) {</code>

<code>            </code><code>futureTask.cancel(</code><code>true</code><code>);</code>

<code>        </code><code>} </code><code>catch</code> <code>(ExecutionException e) {</code>

<code>            </code><code>// 逾時後，進行相應處理</code>

<code>38</code>

<code>        </code><code>} </code><code>finally</code> <code>{</code>

<code>39</code>

<code>            </code><code>System.out.println(</code><code>"task@"</code> <code>+ i + </code><code>":result="</code> <code>+ result);</code>

<code>40</code>

<code>41</code>

<code>42</code>

<code>43</code>

SPRING配置檔案

<code>&lt;?xml version=</code><code>"1.0"</code> <code>encoding=</code><code>"UTF-8"</code><code>?&gt;</code>

<code>&lt;beans xmlns=</code><code>"http://www.springframework.org/schema/beans"</code>

<code>    </code><code>xmlns:xsi=</code><code>"http://www.w3.org/2001/XMLSchema-instance"</code> <code>xmlns:mvc=</code><code>"http://www.springframework.org/schema/mvc"</code>

<code>    </code><code>xmlns:aop=</code><code>"http://www.springframework.org/schema/aop"</code> <code>xmlns:context=</code><code>"http://www.springframework.org/schema/context"</code>

<code>    </code><code>xsi:schemaLocation="</code>

<code>        </code><code>http:</code><code>//www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd</code>

<code>        </code><code>http:</code><code>//www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd</code>

<code>        </code><code>http:</code><code>//www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd</code>

<code>        </code><code>http:</code><code>//www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd</code>

<code>        </code><code>"&gt;</code>

<code>    </code><code>&lt;bean id=</code><code>"threadPoolTaskExecutor"</code>

<code>        </code><code>class</code><code>=</code><code>"org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"</code><code>&gt;</code>

<code>        </code><code>&lt;!-- 核心線程數，預設為</code><code>1</code> <code>--&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"corePoolSize"</code> <code>value=</code><code>"10"</code> <code>/&gt;</code>

<code>        </code><code>&lt;!-- 最大線程數，預設為Integer.MAX_VALUE --&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"maxPoolSize"</code> <code>value=</code><code>"50"</code> <code>/&gt;</code>

<code>        </code><code>&lt;!-- 隊列最大長度，一般需要設定值&gt;=notifyScheduledMainExecutor.maxNum；預設為Integer.MAX_VALUE</code>

<code>            </code><code>&lt;property name=</code><code>"queueCapacity"</code> <code>value=</code><code>"1000"</code> <code>/&gt; --&gt;</code>

<code>        </code><code>&lt;!-- 線程池維護線程所允許的空閑時間，預設為60s --&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"keepAliveSeconds"</code> <code>value=</code><code>"300"</code> <code>/&gt;</code>

<code>        </code><code>&lt;!-- 線程池對拒絕任務（無線程可用）的處理政策，目前隻支援AbortPolicy、CallerRunsPolicy；預設為後者 --&gt;</code>

<code>        </code><code>&lt;property name=</code><code>"rejectedExecutionHandler"</code><code>&gt;</code>

<code>            </code><code>&lt;!-- AbortPolicy:直接抛出java.util.concurrent.RejectedExecutionException異常 --&gt;</code>

<code>            </code><code>&lt;!-- CallerRunsPolicy:主線程直接執行該任務，執行完之後嘗試添加下一個任務到線程池中，可以有效降低向線程池内添加任務的速度 --&gt;</code>

<code>            </code><code>&lt;!-- DiscardOldestPolicy:抛棄舊的任務、暫不支援；會導緻被丢棄的任務無法再次被執行 --&gt;</code>

<code>            </code><code>&lt;!-- DiscardPolicy:抛棄目前任務、暫不支援；會導緻被丢棄的任務無法再次被執行 --&gt;</code>

<code>            </code><code>&lt;bean </code><code>class</code><code>=</code><code>"java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy"</code> <code>/&gt;</code>

<code>        </code><code>&lt;/property&gt;</code>

<code>    </code><code>&lt;/bean&gt;</code>

<code>&lt;/beans&gt;</code>

測試類

<code>package</code> <code>com.zuidaima.test;</code>

<code>import</code> <code>org.junit.Test;</code>

<code>import</code> <code>org.junit.runner.RunWith;</code>

<code>import</code> <code>org.springframework.beans.factory.annotation.Autowired;</code>

<code>import</code> <code>org.springframework.test.context.ContextConfiguration;</code>

<code>import</code> <code>org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;</code>

<code>import</code> <code>org.springframework.test.context.junit4.SpringJUnit4ClassRunner;</code>

<code>import</code> <code>com.zuidaima.threadpool.StartTaskThread;</code>

<code>@RunWith</code><code>(SpringJUnit4ClassRunner.</code><code>class</code><code>)</code>

<code>// 指定的運作runner，并且把你所指定的Runner作為參數傳遞給它</code>

<code>@ContextConfiguration</code><code>(locations = </code><code>"classpath*:applicationContext.xml"</code><code>)</code>

<code>public</code> <code>class</code> <code>TestThreadPool </code><code>extends</code> <code>AbstractJUnit4SpringContextTests {</code>

<code>    </code><code>private</code> <code>static</code> <code>int</code> <code>produceTaskSleepTime = </code><code>10</code><code>;</code>

<code>    </code><code>private</code> <code>static</code> <code>int</code> <code>produceTaskMaxNumber = </code><code>1000</code><code>;</code>

<code>    </code><code>@Autowired</code>

<code>    </code><code>public</code> <code>ThreadPoolTaskExecutor getThreadPoolTaskExecutor() {</code>

<code>        </code><code>return</code> <code>threadPoolTaskExecutor;</code>

<code>    </code><code>public</code> <code>void</code> <code>setThreadPoolTaskExecutor(</code>

<code>            </code><code>ThreadPoolTaskExecutor threadPoolTaskExecutor) {</code>

<code>    </code><code>@Test</code>

<code>    </code><code>public</code> <code>void</code> <code>testThreadPoolExecutor() {</code>

<code>        </code><code>for</code> <code>(</code><code>int</code> <code>i = </code><code>1</code><code>; i &lt;= produceTaskMaxNumber; i++) {</code>

<code>            </code><code>try</code> <code>{</code>

<code>                </code><code>Thread.sleep(produceTaskSleepTime);</code>

<code>            </code><code>} </code><code>catch</code> <code>(InterruptedException e1) {</code>

<code>                </code><code>e1.printStackTrace();</code>

<code>            </code><code>new</code> <code>Thread(</code><code>new</code> <code>StartTaskThread(threadPoolTaskExecutor, i)).start();</code>

<code>44</code>

<code>45</code>

<code>46</code>

<code>47</code>

原文中有些纰漏，我已經修改

項目截圖（基于行家建構）

運作截圖：

如果遇到CPU忙執行超過1秒的會傳回空