【多线程开发 6】spring中的注解/API的线程问题

news2024/9/23 1:42:00

【多线程开发 6】spring中的注解/API的线程问题

2024年8月14日

文章目录

【多线程开发 6】spring中的注解/API的线程问题
- 1 Future和CompletableFuture
- 2 hutool的异步任务
- 3 @Async
- 4 @Schedule
- 5 stream Parallel
- 6 ForkJoinPool
- 7 @Transactional

除了Java自带默认线程池，基于Java的spring框架也有很多自带的默认线程池，有时候我们的一些需要线程池的操作可能通过提供的api和注解隐藏掉了，不熟悉的话会出现线程相关的问题

1 Future和CompletableFuture

Future和CompletableFuture都是Java提供的用来执行异步方法的情况。其中，Future只能包装一个异步任务，最后还是要把这个任务提交给特定线程池。

CompletableFuture则会使用默认线程池，但是比较复杂：

无JVM参数前提下：

若服务器的核心数小于等于2，commonParallelism 则为1，即useCommonPool 为false，new 一个线程池ThreadPerTaskExecutor 。

若服务器的核心数大于2，commonParallelism 则为核心数 - 1，即useCommonPool 为true，使用ForkJoinPool线程池。
有JVM参数情况下：

以设置参数为准。大于1小于等于32767。和上面判断一致

以上CompletableFuture的总结来自这篇文章从用法到源码再到应用场景：全方位了解CompletableFuture及其线程池有兴趣深挖一下的可以看下

综上我们推荐使用CompletableFuture时候也需要主动指定线程池，没有指定线程池的情况下，CompletableFuture要么使用ForkJoinPool，要么不使用线程池，ForkJoinPool做CPU密集型任务好用，我们有时候做IO密集型任务则不需要他，需要指定IO型线程池。

2 hutool的异步任务

hutool在提交任务的时候，会自动提交到一个默认的ExecutorService对象中，这个对象会使用如下的类的builder(0方法，这个对象的参数如下

一些小项目直接使用OK的，但是如果大项目使用的话，风险会较大，他的最大线程数是最大值，任务队列也是1024，不一定满足业务需要，核心线程数是0

在这里插入图片描述

3 @Async

springboot 2.1.0 之前：simpleasynctaskexecutor，这个线程池会是不安全的线程池，很容易出现OOM，因为他创建新线程、无限、不重用

springboot 2.1.0 之后：taskexecutor这个是springboot的一个自带bean，类型是TaskExecutor，一般是有的，如果没有才会找simpleasynctaskexecutor

4 @Schedule

在Spring Boot中，@Scheduled注解是基f于Java的ThreadPoolExecutor和ScheduledThreadPoolExecutor实现的。当我们配置了一个定时任务后，Spring Boot会首先创建一个ScheduledThreadPoolExecutor线程池，并将定时任务添加到该线程池中等待执行。然后，在指定的时间到来之后，线程池会为该定时任务分配一个线程来执行。如果该定时任务还未执行完毕，在下一个周期到达时，线程池会为该任务再次分配一个线程来执行。通过这种方式，@Scheduled可以非常方便地实现周期性的定时任务f于Java的ThreadPoolExecutor和ScheduledThreadPoolExecutor实现的。

当然schedule注解可以指定线程池，需要实现SchedulingConfigurer 方法

    @Configuration
    @DependOn("executor")
    public class ScheduleConfig implements SchedulingConfigurer {
        @Resource
        private ThreadPoolExecutor executor;
        
        @Override
        public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
            //具体逻辑需要自己写
            ThreadPoolTaskScheduler threadPoolTaskScheduler = executor;
        }
    }