SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   & [! ?: h8 |$ U$ J& K( w- F
2. task.core_pool_size=5
     {( C, L9 M$ s! r2 n
3. task.max_pool_size=50
   
4. task.queue_capacity=1000
   
5. task.keep_alive_seconds=60

复制代码

' Y3 G) X( b% R9 U6 e; F6 U二、配置spring的applicationContext.xml添加：
% V6 ^5 Q' z% k! j! a6 b- N9 }" P

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   
2.         <!-- 核心线程数 -->     
   , H- E4 @) F$ d4 ~8 A
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
   
4.         <!-- 最大线程数 -->  
   
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   
6.         <!-- 队列最大长度 -->
   * [0 v4 x% e" x2 u8 e" e6 _, P6 J9 a
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   0 N( E- Y7 }2 b( s+ p
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   . T! i/ T. r) R4 G& W: p; X) P
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   2 M+ w& X1 g8 x( m
10.     </bean>
    . E8 [' L# |$ [) |+ i
11.     <!-- 注解式 -->
    0 d7 R# J8 ~, T1 [2 O* V9 Q
12.     <task:annotation-driven />

复制代码

三、在实现层Impl声明并注入：
6 L  H3 P' E+ J. M/ Z( H

1. @Resource(name = "taskExecutor")
   0 B9 p( ~3 I0 e" n, ~
2.     private TaskExecutor taskExecutor;

复制代码

四、在方法里调用：

1. try {
   
2.             taskExecutor.execute(new Runnable() {
   
3.                 public void run() {
   6 x. h6 J' K1 d
4.                     //这里编写处理业务代码
   ! C8 `  b% A$ h/ P0 L) M% r
5.                     
   3 s* f7 P1 v, @$ A8 b9 {
6.                 }
   + m; l# Z8 Q* k; C. K$ G
7.             });
   - X7 r, {  O. _& r  I- i4 b$ I
8.         } catch (Exception e) {
   % b2 |) r; l" }: Z( W+ Q
9.             e.printStackTrace();
   6 L* T& m* s$ m7 U% r
10.         }

复制代码

# F+ O$ Q! _! ^$ Y3 o1 G7 X- N: h