SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   
2. task.core_pool_size=5
   + r! Q7 S6 g6 x/ I. t- I
3. task.max_pool_size=50
   - l0 T0 {* b# a7 i4 {8 V
4. task.queue_capacity=1000
   
5. task.keep_alive_seconds=60

复制代码

二、配置spring的applicationContext.xml添加：
! }: B& ]9 Y$ T

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   $ n0 B* M0 ]+ P+ Y5 m2 r) ^9 {
2.         <!-- 核心线程数 -->     
   8 }1 a; v( q% q; S- g7 ~4 d4 r
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
   
4.         <!-- 最大线程数 -->  
   
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   
6.         <!-- 队列最大长度 -->
   8 _) C$ G8 {, |
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   ! i% j/ c' m( G2 v* |
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   + f- R, _0 o! T, n5 b: M# S
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   $ z; ]: ?- n; H9 B. X3 W
10.     </bean>
    4 S0 \, T* Q8 o; W
11.     <!-- 注解式 -->
    
12.     <task:annotation-driven />

复制代码

三、在实现层Impl声明并注入：
; Z( t" x" `# S5 b' `9 ]

1. @Resource(name = "taskExecutor")
   5 m1 a" h, U9 b, C" J  g4 b) `; B
2.     private TaskExecutor taskExecutor;

复制代码

四、在方法里调用：
; J' M& p0 G1 J- X. q8 O

1. try {
   4 ]1 ]7 ~  |0 J
2.             taskExecutor.execute(new Runnable() {
   ( ~% [7 l( o% U1 C. ]1 e, _
3.                 public void run() {
   # n$ ]& v7 Z6 T2 z* S9 M
4.                     //这里编写处理业务代码
   * _& Z) p$ \1 l0 R( a
5.                     
   
6.                 }
   
7.             });
   
8.         } catch (Exception e) {
   & c# b% e- R( s; C  W
9.             e.printStackTrace();
   + s' R8 z1 i$ M4 P1 H$ F2 R# W% C
10.         }

复制代码

9 w" r5 V* S9 m) i( t# y; M  A+ Y