SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   # u9 }- |" B+ @6 L' O
2. task.core_pool_size=5
   4 s  Z4 g8 J2 c/ c4 [, C
3. task.max_pool_size=50
   , M1 @6 a# Y6 J, P$ W! `: Z' \
4. task.queue_capacity=1000
   
5. task.keep_alive_seconds=60

复制代码

二、配置spring的applicationContext.xml添加：
1 Q: V& y/ L$ ^* ~% N& p

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   ; T2 e( V' q7 _7 Z! @7 A( n
2.         <!-- 核心线程数 -->     
   / J" s. h! G9 S* C2 D
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
   
4.         <!-- 最大线程数 -->  
   5 R) P. ?- [1 V0 z, \! E. K+ t
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   
6.         <!-- 队列最大长度 -->
   
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   2 E# Q2 Q9 t( O7 A& a; r
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   4 i5 l7 a" E  b7 M
10.     </bean>
    
11.     <!-- 注解式 -->
    ; J4 j4 ?/ f- {& D+ p7 N
12.     <task:annotation-driven />

复制代码

三、在实现层Impl声明并注入：

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

复制代码

7 |' _$ a5 G# ~4 r) x四、在方法里调用：
8 @) H# ?9 L8 z( b3 M3 ^

1. try {
   ! ?8 d! }, v! N- Y# ]
2.             taskExecutor.execute(new Runnable() {
   
3.                 public void run() {
   
4.                     //这里编写处理业务代码
   
5.                     
   
6.                 }
   
7.             });
   - ]0 H/ s, E9 U2 O: G4 u& L
8.         } catch (Exception e) {
   2 @$ ^; Z& }. r, M3 [
9.             e.printStackTrace();
   
10.         }

复制代码