xmlns:task="http://www.springframework.org/schema/task"

xmlns文件并且xsi:schemaLocation中添加

http://www.springframework.org/schema/task 

http://www.springframework.org/schema/task/spring-task.xsd

在spring中配置Executor

1.  
   <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
2.  
   <!-- 核心线程数 -->
3.  
   <property name="corePoolSize" value="${task.core_pool_size}" />
4.  
   <!-- 最大线程数 -->
5.  
   <property name="maxPoolSize" value="${task.max_pool_size}" />
6.  
   <!-- 队列最大长度 -->
7.  
   <property name="queueCapacity" value="${task.queue_capacity}" />
8.  
   <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
9.  
   <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
10.  
    </bean>
11.  
    <!-- 注解式 -->
12.  
    <task:annotation-driven />

在dbconfig.properties添加

1.  
   maxOpenPreparedStatements=20
2.  
   removeAbandoned=true
3.  
   removeAbandonedTimeout=1800
4.  
   logAbandoned=true

这是分别对线程池做配置

1.  
   @Resource(name = "taskExecutor")
2.  
   private TaskExecutor taskExecutor;

1.  
   taskExecutor.execute(new Runnable() {
2.  
    
3.  
   @Override
4.  
   public void run() {
5.  
   // TODO Auto-generated method stub
6.  
   try {
7.  
   //要进行的并发操作
8.  
   } catch (Exception e) {
9.  
   // TODO Auto-generated catch block
10.  
    e.printStackTrace();
11.  
    }
12.  
    }
13.  
    });

1. @Controller
2. public class IndexController {
3. int studentscount = 0;
4. @RequestMapping(value = "/index.html")
5. public ModelAndView goIndex() {
6. logBefore(logger, "列表Center");
7. ModelAndView mv = this.getModelAndView();
8. taskExecutor.execute(new Runnable() {
9. @Override
10. public void run() {
11. // TODO Auto-generated method stub
12. // 得到所有学生人数
13. try {
14. studentscount = coursesService.getStudentCount(pd);
15. } catch (Exception e) {
16. // TODO Auto-generated catch block
17. e.printStackTrace();
18. }
19. }
20. });
21. mv.addObject("studentscount", studentscount);
22. mv.setViewName("common/index");
23. return mv;
24. ｝