使用SPRING中的线程池ThreadPoolTaskExecutor并且得到任务执行的结果

XML配置<bean id="threadPoolTaskExecutor"class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"><!-- 核心线程数，默认为1 --><property name="corePoolSize" value="10" /><!-- 最大线程数，默认为Integer.MAX_VALUE --><property name="maxPoolSize" value="50" /><!-- 队列最大长度，一般需要设置值>=notifyScheduledMainExecutor.maxNum；默认为Integer.MAX_VALUE<property name="queueCapacity" value="1000" /> --><!-- 线程池维护线程所允许的空闲时间，默认为60s --><property name="keepAliveSeconds" value="300" /><!-- 线程池对拒绝任务（无线程可用）的处理策略，目前只支持AbortPolicy、CallerRunsPolicy；默认为后者 --><property name="rejectedExecutionHandler"><!-- AbortPolicy:直接抛出java.util.concurrent.RejectedExecutionException异常 --><!-- CallerRunsPolicy:主线程直接执行该任务，执行完之后尝试添加下一个任务到线程池中，可以有效降低向线程池内添加任务的速度 --><!-- DiscardOldestPolicy:抛弃旧的任务、暂不支持；会导致被丢弃的任务无法再次被执行 --><!-- DiscardPolicy:抛弃当前任务、暂不支持；会导致被丢弃的任务无法再次被执行 --><bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" /></property></bean>

<span style="color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;">用ThreadPoolExecutor的时候，又想知道被执行的任务的执行情况，这时就可以用FutureTask。</span><br style="font-size: 13px; color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; line-height: 20px;" /><span style="color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;">ThreadPoolTask</span>

<span style="color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;"></span><pre name="code" class="java">package com.zuidaima.threadpool;import java.io.Serializable;import java.util.concurrent.Callable;public class ThreadPoolTask implements Callable<String>, Serializable {private static final long serialVersionUID = 0;// 保存任务所需要的数据private Object threadPoolTaskData;private static int consumeTaskSleepTime = 2000;public ThreadPoolTask(Object tasks) {this.threadPoolTaskData = tasks;}public synchronized String call() throws Exception {// 处理一个任务，这里的处理方式太简单了，仅仅是一个打印语句System.out.println("开始执行任务：" + threadPoolTaskData);String result = "";// //便于观察，等待一段时间try {// long r = 5/0;for (int i = 0; i < 100000000; i++) {}result = "OK";} catch (Exception e) {e.printStackTrace();result = "ERROR";}threadPoolTaskData = null;return result;}}

模拟客户端提交的线程package com.zuidaima.threadpool;import java.util.concurrent.ExecutionException;import java.util.concurrent.FutureTask;import java.util.concurrent.TimeUnit;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;public class StartTaskThread implements Runnable {private ThreadPoolTaskExecutor threadPoolTaskExecutor;private int i;public StartTaskThread(ThreadPoolTaskExecutor threadPoolTaskExecutor, int i) {this.threadPoolTaskExecutor = threadPoolTaskExecutor;this.i = i;}@Overridepublic synchronized void run() {String task = "task@ " + i;System.out.println("创建任务并提交到线程池中：" + task);FutureTask<String> futureTask = new FutureTask<String>(new ThreadPoolTask(task));threadPoolTaskExecutor.execute(futureTask);// 在这里可以做别的任何事情String result = null;try {// 取得结果，同时设置超时执行时间为1秒。同样可以用future.get()，不设置执行超时时间取得结果result = futureTask.get(1000, TimeUnit.MILLISECONDS);} catch (InterruptedException e) {futureTask.cancel(true);} catch (ExecutionException e) {futureTask.cancel(true);} catch (Exception e) {futureTask.cancel(true);// 超时后，进行相应处理} finally {System.out.println("task@" + i + ":result=" + result);}}}测试类package com.zuidaima.test;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import com.zuidaima.threadpool.StartTaskThread;@RunWith(SpringJUnit4ClassRunner.class)// 指定的运行runner，并且把你所指定的Runner作为参数传递给它@ContextConfiguration(locations = "classpath*:applicationContext.xml")public class TestThreadPool extends AbstractJUnit4SpringContextTests {private static int produceTaskSleepTime = 10;private static int produceTaskMaxNumber = 1000;@Autowiredprivate ThreadPoolTaskExecutor threadPoolTaskExecutor;public ThreadPoolTaskExecutor getThreadPoolTaskExecutor() {return threadPoolTaskExecutor;}public void setThreadPoolTaskExecutor(ThreadPoolTaskExecutor threadPoolTaskExecutor) {this.threadPoolTaskExecutor = threadPoolTaskExecutor;}@Testpublic void testThreadPoolExecutor() {for (int i = 1; i <= produceTaskMaxNumber; i++) {try {Thread.sleep(produceTaskSleepTime);} catch (InterruptedException e1) {e1.printStackTrace();}new Thread(new StartTaskThread(threadPoolTaskExecutor, i)).start();}}}

<pre name="code" class="html" style="display: inline !important;"><span style="color: rgb(51, 51, 51); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;">原文:</span><a target=_blank href="http://www.blogjava.net/paulwong/archive/2011/12/07/365773.html" target="_blank" rel="nofollow" style="font-size: 13px; color: rgb(0, 136, 204); text-decoration: none; font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; line-height: 20px;">http://www.blogjava.net/paulwong/archive/2011/12/07/365773.html</a>