SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   
2. task.core_pool_size=5
   
3. task.max_pool_size=50
   
4. task.queue_capacity=1000
   $ C7 D  ]+ o5 i* t( v9 |; E9 X, V
5. task.keep_alive_seconds=60

复制代码

  s# u0 n0 D+ k+ C7 O5 y& |2 |- ^6 }二、配置spring的applicationContext.xml添加：

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   
2.         <!-- 核心线程数 -->     
   4 B' y. ~0 Z% v- ~+ c1 {
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
   " {* S2 [# Q( b
4.         <!-- 最大线程数 -->  
   
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   / T3 ?0 G9 i. k
6.         <!-- 队列最大长度 -->
   
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   0 U& O" O# y3 t: N9 B  N0 j: ?0 Q
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   2 s: N: Z8 c. R- w
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   
10.     </bean>
    ! s) R0 x1 Z. ^' A4 X) `
11.     <!-- 注解式 -->
    * l, o) r6 ^/ }, J2 ]* {* t  _7 x
12.     <task:annotation-driven />

复制代码

三、在实现层Impl声明并注入：
0 W, z2 r' W" T! M

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

复制代码

四、在方法里调用：

1. try {
   
2.             taskExecutor.execute(new Runnable() {
   
3.                 public void run() {
   9 ?+ V" C3 u  G! T/ S+ ]
4.                     //这里编写处理业务代码
   
5.                     
     X& R1 Z2 V) T* |3 C7 ~# e. D" L: o
6.                 }
   
7.             });
   
8.         } catch (Exception e) {
   
9.             e.printStackTrace();
   
10.         }

复制代码

# W* b( z7 t7 b$ w& ]