MyThreadPoolExecutor.java
1.23 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
package com.zteits.job.util;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* Copyright: Copyright (c) 2018 zteits
*
* @ClassName: com.clouds.common.threadpool
* @Description: 自定义线程池 替代spring 默认实现的线程池
* @version: v1.0.0
* @author: atao
* @date: 2018/3/22 下午7:59
* Modification History:
* Date Author Version Description
* ---------------------------------------------------------*
* 2018/3/22 atao v1.0.0 创建
*/
@Configuration
public class MyThreadPoolExecutor {
// 线程池维护线程的最少数量
private static final int SIZE_CORE_POOL = 15;
// 线程池维护线程的最大数量
private static final int SIZE_MAX_POOL = 15;
@Bean
public ThreadPoolTaskExecutor myTaskAsyncPool() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(SIZE_CORE_POOL);
executor.setMaxPoolSize(SIZE_MAX_POOL);
executor.setThreadNamePrefix("MyTaskAsyncPool-");
executor.initialize();
return executor;
}
}