SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   1 O8 R3 R$ C* |( r: v' z: H% h$ u
2. task.core_pool_size=5
   
3. task.max_pool_size=50
   ! l9 y! F7 w5 r. L$ Y1 g& a3 A
4. task.queue_capacity=1000
   
5. task.keep_alive_seconds=60

复制代码

$ _0 C( X) Y" @6 \8 \$ e二、配置spring的applicationContext.xml添加：

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   
2.         <!-- 核心线程数 -->     
   
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
   
4.         <!-- 最大线程数 -->  
   
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   
6.         <!-- 队列最大长度 -->
   
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   : t- o' F" H2 G4 q1 h' {1 ~' y0 T
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   
10.     </bean>
    
11.     <!-- 注解式 -->
    ( M" Z' C1 c9 [6 W
12.     <task:annotation-driven />

复制代码

三、在实现层Impl声明并注入：
# S6 l' z) m. @1 |

1. @Resource(name = "taskExecutor")
     E2 j2 ^, I; G
2.     private TaskExecutor taskExecutor;

复制代码

! v/ I4 e# q3 i' D/ D四、在方法里调用：

1. try {
   
2.             taskExecutor.execute(new Runnable() {
   , T0 [, x' c5 R
3.                 public void run() {
   . g4 O7 c! @7 o8 \& d1 d1 V
4.                     //这里编写处理业务代码
     o% p5 T! V; J4 ]7 ?6 ^1 B0 R: X
5.                     
   
6.                 }
   / [! T8 z/ ?9 M: i/ Y; ~
7.             });
   " _1 m1 P# I+ P+ ~/ O, q! x8 U
8.         } catch (Exception e) {
   
9.             e.printStackTrace();
   ) A! s" {+ \/ N
10.         }

复制代码

+ q, r1 j9 k6 [  M4 n& a, G