线程池与CompletableFuture

---

线程池

• 线程池和数据库连接池类似，可以统一管理维护线程，减少没有必要的开销，就是说你在需要启动线程的时候没有必要自己创建了，只需要从线程池拿就行了，如果用完了还回去就行了没必要创建一个新的，比如说我需要100个线程，我如果说直接创建100个线程一个任务占用一份，用完就扔跟方便筷子似的那就太浪费了。我可以创建一个线程池里面只有10个线程，然后用完了还回来，下一个任务来了接着用，那这样的话我就开10个线程就行了。至于说谁先用，怎么用可以通过线程池去维护。
• jdk自带4种线程池
• 4种默认线程池介绍

Executors new CachedThreadPool()：可缓存线程池
Executors new FixedTheadPool()：可定长度
Executors new ScheduledThreadPool()：可定时
Executors new SingleTheadExecutor()：单例

但在springboot当中一般使用spring自带的
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
ThreadPoolExecutor是Java原生的线程池类，而ThreadPoolTaskExecutor是Spring推出的线程池工具

ThreadPoolTaskExecutor 和 ThreadPoolExecutor 的区别
ThreadPoolTaskExecutor和ThreadPoolExecutor有何区别
ThreadPoolTaskExecutor和ThreadPoolExecutor区别

线程池构造函数里面的参数

corePoolSize：核心线程数即一直运行的线程数
maximumPoolSize：最大线程数
keepAliveTime：超出corePoolSize后创建线程的存活时间
unit：KeepAliveTime的时间单位
workQueue：任务队列，用于保存待执行的任务
threadFactory：线程池内部创建线程所用的工厂
handler：任务无法执行时的处理器

拒绝策略

AbortPolicy：丢弃任务，抛运行时异常
CallerRunsPolicy：执行任务
DiscardPolicy：忽视，什么都不会发生
DiscardOldestPolicy：从队列中踢出最先进入队列(最后一个执行)的任务。
实现RejectedExecutionHandler接口，可自定义处理器。

如何使用

在springboot中使用线程池十分简单，可参考

Spring Boot 中的线程池，这也太好用了！

比如你需要异步导入excel
只需要先在启动类加个@EnableAsync开启异步线程池
在写个配置类

@Configuration
@EnableAsync
public class ExeConfig {

    private static final Logger logger = LoggerFactory.getLogger(ExeConfig.class);

    @Bean
    public Executor asyncServiceExecutor() {
        logger.info("start asyncServiceExecutor");
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //配置核心线程数
        executor.setCorePoolSize(10);
        //配置最大线程数
        executor.setMaxPoolSize(30);
        //配置队列大小
        executor.setQueueCapacity(99999);
        //配置线程池中的线程的名称前缀
        executor.setThreadNamePrefix("excle-async-service-");

        // rejection-policy：当pool已经达到max size的时候，如何处理新任务
        // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //执行初始化
        executor.initialize();
        return executor;
    }

}
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

在写个实现类就行
方法1

@Slf4j
@Service
public class AsyncExportService {
    @Async("asyncServiceExecutor")
    public void exportXXX() {
    //业务代码
}
1
2
3
4
5
6
7

然后注入使调用

@Autowired
private AsyncExportService asyncExportService;
      ...
      ...
AsyncExportService.exportXXX();
               ...
1
2
3
4
5
6

当然也可以把异步方法直接写在原本类似这种,就不用另外启用异步类来写异步方法了@Async(“asyncServiceExecutor”)注解了，但是还是推荐写法1，将异步方法放一起。
方法2

@Autowired
 private ThreadPoolTaskExecutor threadPoolTaskExecutor;
      ...
      ...
    threadPoolTaskExecutor.execute(() ->this.incr(tagId,TAG_CLICK_VOLUME));
                 ...


   public void incr(Long id,String key) {
        Map<String, Object> map = redisService.getCacheMap(key);
        Integer value = (Integer) map.get(id.toString());
        // 如果key存在就直接加一
        if (value != null) {
            map.put(id.toString(),value+1);
        }else {
            map.put(id.toString(),1);
        }
        redisService.setCacheMap(key,map);
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

调用A接口返回a耗时1分钟，调用B接口返回b耗时1分钟，怎么使得a+b在1分钟左右
IO密集型和计算密集型(CPU密集型)具体的区分
线程池的大小如何确定
单核与多核

相关连接

线程池常见的面试题
记录一次学习总结线程池原理与其API