【多线程开发 6】spring中的注解/API的线程问题
【多线程开发 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 {@Resourceprivate ThreadPoolExecutor executor;@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {//具体逻辑需要自己写ThreadPoolTaskScheduler threadPoolTaskScheduler = executor;}}或者可以再schedule注解上再加一个 @Async注解，做到异步线程中去做。
5 stream Parallel
parallelStream不能使用自定义线程池，默认情况下，Stream使用的是ForkJoinPool.commonPool()，这是一个公用的线程池，被整个程序所使用。
但是stream parallel本身就符合ForkJoinPool的Fork/Join思想，一般不会去进行修改。但是如果有需要，我们可以单独给并行流创建一个线程池供他们使用。
如创建一个并行度为4的ForkJoinPool，通过给该ForkJoinPool提交lambda表达式任务来解决这个问题
6 ForkJoinPool
详情可以参照该文章 线程池ForkJoinPool简介
7 @Transactional
使用该注解时不能做和多线程/异步线程相关的事情，否则事务容易失效，详情请见 注解@Transactional 原理和常见的坑
引用文章：
- Spring中异步注解@Async的使用、原理及使用时可能导致的问题
- Async注解不指定线程池？默认用的又是什么？
- hutool官网
- 从用法到源码再到应用场景：全方位了解CompletableFuture及其线程池
- SpringBoot定时任务@Scheduled的多线程使用
- 注解@Transactional 原理和常见的坑
- 线程池ForkJoinPool简介
- 多线程场景下谨慎使用@Transactional注解，你不信我也没办法
- https://blog.csdn.net/qq_33709582/article/details/132686293)