Spring3.2.6定时任务+线程池.docx

Spring3.2.6 框架多线程序配置【定时任务+线程池】费劲周折终于把这个功能配置起来了，在网上找到很多资料，大多数例子基本都是相互拷贝，前后不搭调，搞得不知所措。因此我把这次配置可以完整运行的示例程序整理出来，分享，希望有时间再进一步优化，共同进步。Spring配置文件： 程序对应的类：MainPro.javapackage com.tz.controller;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;/* * 要起动的主线程 * author wyg20151013 */public class MainPro implements Runnable private ThreadPoolTaskExecutor taskExecutor; public MainPro()public MainPro(ThreadPoolTaskExecutor taskExecutor)this.taskExecutor = taskExecutor; public ThreadPoolTaskExecutor getTaskExecutor() return taskExecutor;public void setTaskExecutor(ThreadPoolTaskExecutor taskExecutor) this.taskExecutor = taskExecutor; public void run() for(int i = 0; i 0) try Thread.sleep(5000); catch (InterruptedException e) e.printStackTrace(); System.out.println(主线程分配完毕); /* * 这个子线程来就是我们系统要处理的任务 * author wyg20151013 */ private class MessagePrinterTask implements Runnable private String message; public MessagePrinterTask(String message) this.message = message; public void run() System.out.println(message); 补充知识：1、解析spring schedule来源：/cutesource/article/details/4900020Spring在schedule这块支持JDK Timer、concurrent、quartz三种，这三种任务调度方案在实现机制和调用方法上都不同，但spring通过对其包装，使得基于spring能用统一的配置和编码风格来使用这三种schedule方案。总得来说这三种schedule都是基于scheduler-trigger-job的基本流程，因此spring通过TimerFactoryBean、ScheduledExecutorFactoryBean和SchedulerFactoryBean分别实现JDK Timer、concurrent和quartz的基本流程。主要逻辑如下代码所示：TimerFactoryBeanjavaview plaincopy1. publicvoidafterPropertiesSet()2. (InitializingTimer);3. this.timer=createTimer(this.beanName,this.daemon);4. /RegisterspecifiedScheduledTimerTasks,ifnecessary.5. if(!ObjectUtils.isEmpty(this.scheduledTimerTasks)6. /注册task和timerregisterTasks(this.scheduledTimerTasks,this.timer);7. 8. ScheduledExecutorFactoryBeanc-sharpview plaincopy1. publicvoidafterPropertiesSet()2. if(logger.isInfoEnabled()3. (InitializingScheduledExecutorService+4. (this.beanName!=null?+this.beanName+:);5. 6. ScheduledExecutorServiceexecutor=7. createExecutor(this.poolSize,this.threadFactory,this.rejectedExecutionHandler);8. /RegisterspecifiedScheduledExecutorTasks,ifnecessary.9. if(!ObjectUtils.isEmpty(this.scheduledExecutorTasks)10. registerTasks(this.scheduledExecutorTasks,executor);11. 12. /Wrapexecutorwithanunconfigurabledecorator.13. this.executor=(this.exposeUnconfigurableExecutor?14. Executors.unconfigurableScheduledExecutorService(executor):executor);15. SchedulerFactoryBeanc-sharpview plaincopy1. publicvoidafterPropertiesSet()throwsException2. .3. /初始化sceduler4. initSchedulerFactory(schedulerFactory);5. this.scheduler=createScheduler(schedulerFactory,this.schedulerName);6. /注册listener、trigger和job7. registerListeners();8. registerJobsAndTriggers();9. .10. /启动scheduler11. startScheduler(this.scheduler,this.startupDelay);12. .13. 14. 顺着scheduler-trigger-job的思路，Spring又分别对JDK Timer、concurrent、quartz的trigger进行了封