Spring3.2.6定時(shí)任務(wù)+線(xiàn)程池

1、Spring3.2.6 框架多線(xiàn)程序配置【定時(shí)任務(wù)+線(xiàn)程池】費(fèi)勁周折終于把這個(gè)功能配置起來(lái)了，在網(wǎng)上找到很多資料，大多數(shù)例子基本都是相互拷貝，前后不搭調(diào)，搞得不知所措。因此我把這次配置可以完整運(yùn)行的示例程序整理出來(lái)，分享，希望有時(shí)間再進(jìn)一步優(yōu)化，共同進(jìn)步。Spring配置文件：<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-/SPRING/DTD BEAN/EN" "/dt

2、d/spring-beans.dtd"><beans> <!- 線(xiàn)程池 -> <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!- 核心線(xiàn)程數(shù) -> <property name="corePoolSize" value="4" /> <!- 最大線(xiàn)程數(shù) -> <proper

3、ty name="maxPoolSize" value="8" /> <!- 隊(duì)列最大長(zhǎng)度 -> <property name="queueCapacity" value="200" /> <!- 線(xiàn)程池維護(hù)線(xiàn)程所允許的空閑時(shí)間 -> <property name="keepAliveSeconds" value="300" /> <!- 線(xiàn)程池對(duì)拒絕任務(wù)(無(wú)線(xiàn)程可用)的處理策略 -> <property

4、 name="rejectedExecutionHandler"> <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" /> </property> </bean> <bean id="mainProcess" class="com.tz.controller.MainPro"> <property name="taskExecutor" ref=

5、"taskExecutor" /> </bean> <bean id="springScheduleExecutorTask" class="org.springframework.scheduling.concurrent.ScheduledExecutorTask"> <!- 要啟動(dòng)的主線(xiàn)程 -> <property name="runnable" ref="mainProcess" /> <!- 容器加載運(yùn)行延遲1秒 ->

6、<property name="delay" value="1000" /> <!- 任務(wù)間隔時(shí)間（sleep時(shí)間）執(zhí)行完第一組任務(wù)，執(zhí)行第二組任務(wù)相隔時(shí)間，兩個(gè)任務(wù)在時(shí)間上不應(yīng)該相交 -> <property name="period" value="10000" /> </bean> <bean id="springScheduledExecutorFactoryBean" class="org.springframework.

7、scheduling.concurrent.ScheduledExecutorFactoryBean"> <property name="scheduledExecutorTasks"> <list> <ref bean="springScheduleExecutorTask" /> </list> </property> </bean> </beans>程序?qū)?yīng)的類(lèi)：MainPro.javapackage com.tz.controller;import

8、 org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;/* * 要起動(dòng)的主線(xiàn)程 * author wyg20151013 */public class MainPro implements Runnable private ThreadPoolTaskExecutor taskExecutor; public MainPro()public MainPro(ThreadPoolTaskExecutor taskExecutor)this.taskExecutor = taskExecutor; public Thre

9、adPoolTaskExecutor getTaskExecutor() return taskExecutor;public void setTaskExecutor(ThreadPoolTaskExecutor taskExecutor) this.taskExecutor = taskExecutor; public void run() for(int i = 0; i < 25; i+) taskExecutor.execute(new MessagePrinterTask("Message = " + i); /等待池中線(xiàn)程執(zhí)行完 while(taskEx

10、ecutor.getActiveCount()>0) try Thread.sleep(5000); catch (InterruptedException e) e.printStackTrace(); System.out.println("主線(xiàn)程分配完畢"); /* * 這個(gè)子線(xiàn)程來(lái)就是我們系統(tǒng)要處理的任務(wù) * author wyg20151013 */ private class MessagePrinterTask implements Runnable private String message; public MessagePrinterTask(St

11、ring message) this.message = message; public void run() System.out.println(message); 補(bǔ)充知識(shí)：1、解析spring schedule來(lái)源：Spring在schedule這塊支持JDK Timer、concurrent、quartz三種，這三種任務(wù)調(diào)度方案在實(shí)現(xiàn)機(jī)制和調(diào)用方法上都不同，但spring通過(guò)對(duì)其包裝，使得基于spring能用統(tǒng)一的配置和編碼風(fēng)格來(lái)使用這三種schedule方案。總得來(lái)說(shuō)這三種schedule都是基于scheduler->trigger->job的基本流程，因此spring

12、通過(guò)TimerFactoryBean、ScheduledExecutorFactoryBean和SchedulerFactoryBean分別實(shí)現(xiàn)JDK Timer、concurrent和quartz的基本流程。主要邏輯如下代碼所示：TimerFactoryBeanjava view plaincopy1. public void afterPropertiesSet()   2.         ("Initializing

13、 Timer");  3.         this.timer = createTimer(this.beanName, this.daemon);  4.         / Register specified ScheduledTimerTasks, if necessary. &

14、#160;5.         if (!ObjectUtils.isEmpty(this.scheduledTimerTasks)   6. /注冊(cè)task和timer          registerTasks(this.scheduledTimerTasks, this.timer);  7.     

15、;      8.       ScheduledExecutorFactoryBeanc-sharp view plaincopy1. public void afterPropertiesSet()   2.         if (logger.isInfoEnabled()   3.

16、60;           ("Initializing ScheduledExecutorService" +  4.                     (this.beanName !=&

17、#160;null ? " '" + this.beanName + "'" : "");  5.           6.         ScheduledExecutorService executor =&

18、#160; 7.                 createExecutor(this.poolSize, this.threadFactory, this.rejectedExecutionHandler);  8.         / Register specified 

19、ScheduledExecutorTasks, if necessary.  9.         if (!ObjectUtils.isEmpty(this.scheduledExecutorTasks)   10.             registerTasks(this.scheduledExecutorTa

20、sks, executor);  11.           12.         / Wrap executor with an unconfigurable decorator.  13.         this.exec

21、utor = (this.exposeUnconfigurableExecutor ?  14.                 Executors.unconfigurableScheduledExecutorService(executor) : executor);  15.      

22、60;SchedulerFactoryBeanc-sharp view plaincopy1. public void afterPropertiesSet() throws Exception   2.     .  3.         / 初始化sceduler  4.       

23、  initSchedulerFactory(schedulerFactory);  5.         this.scheduler = createScheduler(schedulerFactory, this.schedulerName);  6.                 /注冊(cè)listener、trigger和job  7.         registerListeners();  8.