SpringMVC如何配置TaskExecutor线程池

admin

一、配置jdbc.properties添加：

1. #------------ Task ------------
   ) u; U( A% Q! r8 T0 v( d. Z+ A6 z
2. task.core_pool_size=5
   
3. task.max_pool_size=50
   
4. task.queue_capacity=1000
   ; e% B+ H% i/ I  R: e
5. task.keep_alive_seconds=60

复制代码

二、配置spring的applicationContext.xml添加：

1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
   # _- n& `  S. E( f' h3 q$ [% ]% m
2.         <!-- 核心线程数 -->     
   6 M4 c3 z! f5 _8 j3 i) c
3.         <property name="corePoolSize" value="${task.core_pool_size}" />
   % |; n* o; G, ^" x
4.         <!-- 最大线程数 -->  
   $ \3 {' X3 f7 j9 |% p2 b' i
5.         <property name="maxPoolSize" value="${task.max_pool_size}" />
   1 S2 o; G3 N) i# q6 s, A* H& k
6.         <!-- 队列最大长度 -->
   0 a0 b2 x; H, @1 q7 j+ v& v% X
7.         <property name="queueCapacity" value="${task.queue_capacity}" />
   * Z; i1 \5 l4 V/ v9 Q' G& ?
8.         <!-- 线程池维护线程所允许的空闲时间，默认为60s -->
   5 ?" c$ T2 \7 I+ K+ `
9.         <property name="keepAliveSeconds" value="${task.keep_alive_seconds}" />
   
10.     </bean>
    / E. O2 p" G( I8 f# x9 V
11.     <!-- 注解式 -->
    * y/ ^! t9 v9 L6 e! E% B3 O
12.     <task:annotation-driven />

复制代码

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

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

复制代码

( g2 e# h$ g% T- F/ e四、在方法里调用：

1. try {
   3 D( l6 T# k: u9 x
2.             taskExecutor.execute(new Runnable() {
   ) {1 `, E& G- ?5 A; y
3.                 public void run() {
   " l4 h( q  ~' E9 N
4.                     //这里编写处理业务代码
   & S8 f( f% w& [, R3 C
5.                     
   
6.                 }
   
7.             });
   , Y; r. E6 @. J: H% T
8.         } catch (Exception e) {
   
9.             e.printStackTrace();
   
10.         }

复制代码

/ u. C; |; W) P$ }( E