載入xml檔案

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

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

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

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

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

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 />  

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
        <!-- 核心執行緒數 -->     
        <property name="corePoolSize" value="${task.core_pool_size}" />
        <!-- 最大執行緒數 -->  
        <property name="maxPoolSize" value="${task.max_pool_size}" />
        <!-- 佇列最大長度 -->
        <property name="queueCapacity" value="${task.queue_capacity}" />
        <!-- 執行緒池維護執行緒所允許的空閒時間，預設為60s -->
        <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
    </bean>
    <!-- 註解式 -->
    <task:annotation-driven />

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

maxOpenPreparedStatements=20
removeAbandoned=true
removeAbandonedTimeout=1800
logAbandoned=true

新增依賴注入

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

@Resource(name = "taskExecutor")
private TaskExecutor taskExecutor;

使用執行緒池進行併發操作

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

			taskExecutor.execute(new Runnable() {

				@Override
				public void run() {
					// TODO Auto-generated method stub
					try {
                                          //要進行的併發操作
					} catch (Exception e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			});
			

提示

1. @Controller
2. publicclass 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.                 publicvoid 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. ｝  

@Controller
public class IndexController {
int studentscount = 0;
@RequestMapping(value = "/index.html")
	public ModelAndView goIndex() {
		logBefore(logger, "列表Center");
		ModelAndView mv = this.getModelAndView();
                taskExecutor.execute(new Runnable() {

				@Override
				public void run() {
					// TODO Auto-generated method stub
					// 得到所有學生人數
					try {
                                          studentscount = coursesService.getStudentCount(pd);
					} catch (Exception e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}

				}
			});
                  mv.addObject("studentscount", studentscount);
                  mv.setViewName("common/index");
                  return mv;
｝