SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   
2. task.core_pool_size=5
   
3. task.max_pool_size=50
   # B9 p; Y  O# {  U5 C+ }, g/ \/ Q
4. task.queue_capacity=1000
   
5. task.keep_alive_seconds=60

复制代码

! E& c5 J$ U7 y. C( d; K2 x二、配置spring的applicationContext.xml添加：
- e- i3 N8 f5 l6 c8 b4 q

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   0 D  I# _% K6 ?0 n6 S' |8 |
2.         <!-- 核心线程数 -->     
     h  p& }# z7 d: }4 G9 Q
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
     p" R$ n- G# m; i/ H& B+ K9 }
4.         <!-- 最大线程数 -->  
   : H# M( m2 j6 E2 b% p& F
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   ( P4 g- I. n, |$ i% f) @. n
6.         <!-- 队列最大长度 -->
   
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   - D, v  _. G6 e0 S+ M& m7 @5 W! c
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   
10.     </bean>
    2 U6 }! M& q) I
11.     <!-- 注解式 -->
    ; _( l. i- S3 Z
12.     <task:annotation-driven />

复制代码

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

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

复制代码

四、在方法里调用：

1. try {
   / Y. o0 o' F/ e& k0 `5 E
2.             taskExecutor.execute(new Runnable() {
   " i2 u( i7 x/ k9 ~& a0 F: l
3.                 public void run() {
   
4.                     //这里编写处理业务代码
   
5.                     
   % o7 J$ `8 }( K% g7 n; c* l) ]- b9 h& ~
6.                 }
   4 d7 A2 X% G) |7 I! j5 w1 r  a6 J. O
7.             });
   
8.         } catch (Exception e) {
   
9.             e.printStackTrace();
   4 X. d  Q$ J$ c; h1 @
10.         }

复制代码

+ |; D* `' A  K" q4 G; @