springboot的调度服务与异步服务实操

1.调度服务

1.1.JDK之ScheduledExecutorService

讲到调度任务，我们脑海里马上会想到ScheduledExecutorService。

ScheduledExecutorService是 Java java.util.concurrent 包中的一个接口，它继承自 ExecutorService 接口。它主要用于在给定的延迟后运行任务，或者定期地执行任务。这个接口提供了几种安排任务执行的方法，包括单次执行、定期执行和周期性执行。

以下是 ScheduledExecutorService 提供的一些关键方法：

  1. schedule(Callable<V> callable, long delay, TimeUnit unit)： 安排所提交的 Callable 任务在指定的延迟后运行，返回一个 Future，代表任务的结果。

  2. schedule(Runnable command, long delay, TimeUnit unit)： 安排所提交的 Runnable 任务在指定的延迟后运行。

  3. scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)： 安排所提交的 Runnable 任务在指定的初始延迟后首次启动，并且随后按指定的周期重复执行。

  4. scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)： 安排所提交的 Runnable 任务在指定的初始延迟后首次启动，并且随后在每次执行结束和下次执行开始之间都存在指定的延迟。

然而，如果采用了sprintboot，我们也可以直接采用springboot提供的调试线程池。这其中有一个最大的优势在于，可以利用spring的cron表达式，采用方法注解的方式，不用引入quartz第三方工具。

1.2.springboot使用调度线程池

我们尝试从源代码的角度，来看看springboot提供的调度线程池是怎么创建的。

首先，启用调度配置，启动类加上@EnableScheduling

springboot的自动配置类一般以AutoConfiguration作为后缀，采用模糊搜索ScheduleAutoConfiguration可以找到目标TaskSchedulingAutoConfiguration。

从截图我们可以看出，我们只需在application.yml加入以下的配置就可以启动了

spring:task:## 定时任务(业务上定时任务量不多，2个足矣)scheduling:## 线程池核心线程数量pool:size: 2## 线程名称前线threadNamePrefix: common-scheduling-

spring对线程池进行二次封闭，最终调用的还是jdk的ThreadPoolExecutor类，我们在该类的构造函数打个断点，可以看到，pool.size参数已经被传参：

1.3.ThreadPoolExecutor核心参数与执行流程

这里有必要先介绍下 ThreadPoolExecutor类的几个函数参数及基本运行机制

构造函数参数：

  1. 核心线程数（Core Pool Size）： 线程池中始终保持的线程数量，即使它们处于空闲状态。如果任务数量少于核心线程数，线程池会创建新的线程来处理任务，而不会立即回收这些线程。

  2. 最大线程数（Maximum Pool Size）： 线程池中允许的最大线程数量。如果任务数量超过了核心线程数但小于最大线程数，且工作队列已满，线程池会创建新的线程来处理任务，直到达到最大线程数。

  3. 工作队列（Work Queue）： 用于存放待执行任务的阻塞队列。当所有核心线程都在忙碌时，新的任务会被放入工作队列中等待执行。

  4. 线程工厂（Thread Factory）： 用于创建新线程的工厂。它提供了一种方式来定制线程的创建过程，例如设置线程的名称、优先级、是否为守护线程等。

  5. 拒绝策略（Rejected Execution Handler）： 当任务无法被线程池及时处理时（即当线程池已满，且工作队列已满），线程池会采用拒绝策略来处理新提交的任务。常见的拒绝策略包括：

    • AbortPolicy：抛出 RejectedExecutionException。
    • CallerRunsPolicy：由调用者线程运行该任务。
    • DiscardPolicy：静默丢弃任务。
    • DiscardOldestPolicy：丢弃队列中最老的任务，然后尝试再次提交当前任务。

  6. 保持活动时间（Keep-Alive Time）： 非核心线程空闲时在终止前等待新任务的最长时间。如果线程池允许核心线程空闲，这个参数也适用于核心线程。

  7. 时间单位（Time Unit）： 与保持活动时间配合使用的时间单位，例如 TimeUnit.SECONDS。

执行流程：

  1. 如果线程池中的线程数量少于核心线程数，即使有空闲线程，线程池也会优先创建新线程来执行新的任务。
  2. 如果线程池中的线程数量达到核心线程数，新的任务会被放入工作队列等待执行。
  3. 如果工作队列已满且线程数量少于最大线程数，线程池会创建新的非核心线程来执行任务。
  4. 如果工作队列已满且线程数量达到最大线程数，新的任务会被拒绝，线程池会采用拒绝策略来处理。

1.4.自定义线程池

由于spingboot对调度任务线程池的参数支持有限，如果想定制自己的参数，可以注入自己的调度线程池，从代码可看出：

@Configuration
public class ThreadPoolConfig {@Beanpublic ScheduledExecutorService scheduledExecutorService() {return new ScheduledThreadPoolExecutor(2,new NamedThreadFactory("common-schedule"),new ThreadPoolExecutor.CallerRunsPolicy()) {@Overrideprotected void afterExecute(Runnable r, Throwable t) {super.afterExecute(r, t);}};}}

1.5.spring cron注解

Cron 表达式是一种用于描述定时任务触发时间的字符串表达式。它由多个时间字段组成，每个字段代表定时任务在特定时间单位上的触发条件。

1.5.1.cron表达式语法格式

秒 分 时 日 月 星期 年份

其中，每个时间字段都有对应的取值范围和特殊符号。下面是每个时间字段的详细说明：

1、秒（Seconds）：取值范围为 0~59。例如，`0/5` 表示从0秒开始，每隔 5 秒触发一次，`*` 表示每秒都触发。

2、分钟（Minutes）：取值范围为 0~59。例如，`0/5` 表示从0分钟开始，每隔 5 分钟触发一次，`*` 表示每分钟都触发。

3、小时（Hours）：取值范围为 0~23。例如，`0/2` 表示从0小时开始，每隔 2 小时触发一次，`*` 表示每小时都触发。

4、日期（Day of Month）：取值范围为 1~31。例如，`1,15` 表示每月的 1 日和 15 日触发，`*` 表示每天都触发。

5、月份（Month）：取值范围为 1~12，也可以使用英文缩写 JAN、FEB、MAR 等。例如，`1,6` 表示一月和六月触发，`*` 表示每个月都触发。

6、 星期（Day of Week）：取值范围为 1~7，1 表示星期日，2 表示星期一，以此类推，也可以使用英文缩写 SUN、MON、TUE 等。例如，`2-6` 表示星期一到星期五触发，`*` 表示每个星期都触发。

7、年份（Year）：可选字段，表示触发条件的年份。例如，`2023` 表示在 2023 年触发，`*` 表示每年都触发。

除了取值范围，Cron 表达式还支持一些特殊符号，用于指定特定的触发条件，例如：

- 星号（*）：代表所有可能的取值，表示不限制该时间字段的取值范围。
- 问号（?）：仅在日期和星期字段中使用，表示不指定具体的取值，可以任意匹配。
- 斜线（/）：表示间隔触发，例如在分钟字段中，"*/5" 表示每隔 5 分钟触发一次。
- 逗号（,）：用于指定多个取值，例如在小时字段中，"1,3,5" 表示在第 1、3、5 小时触发。
- 减号（-）：用于指定一个范围，例如在月份字段中，"3-6" 表示三月到六月触发。

L  : 表示最后，只能出现在星期和每月第几天域，如果在星期域使用1L，意味着在最后的一个星期日触发。  

 W  : 表示有效工作日(周一到周五),只能出现在每月第几日域，系统将在离指定日期的最近的有效工作日触发事件。注意一点，W的最近寻找不会跨过月份  

 LW  : 这两个字符可以连用，表示在某个月最后一个工作日，即最后一个星期五。  

 #  : 用于确定每个月第几个星期几，只能出现在每月第几天域。例如在1#3，表示某月的第三个星期日。

1.5.2.cron表达式示例

作用表达式
每隔5秒执行一次*/5  *  *  *  *  ?
每天中午12点执行一次0 0 12 * * ?

2024年的每天上午10:00执行一次		0 0 10 * * ? 2023
每天下午6点到下午6:59每分钟执行一次0 * 18 * * ?
每月的最后一个星期五上午10:30执行一次0 30 10 ? * 6L
每月的第4个星期五上午10:25执行一次0  25  10  ?  *  6#4
每天上午8点，下午1点，4点执行一次0  0  8,13,16  * * ?

2.异步任务

2.1.springboot配置

在软件开发中，有些任务比较耗时但又无需马上获得结果。一般地，这些任务我们可以采用独立线程池异步执行。如果程序基于springboot环境，我们有现成的工具可以使用。
首先，我们需要在程序启动入口类增加@EnableAsync。
借着，我们尝试从源代码的角度，来看看springboot提供的异步线程池是怎么创建的。
从springboot的命名风格可知，通过模糊搜索TaskAutoConfiguration，可以找到TaskExecutionAutoConfiguration，如下：

从源代码可知，只需在application.yml配置如下参数即可： 

spring:    execution:pool:coreSize: 4queueCapacity: 64maxSize: 8## 禁止空闲线程关闭，保证最少有core个存活线程allowCoreThreadTimeout: falsekeepAlive: 300sthreadNamePrefix: common-async_task-

这些参数跟jdk的ThreadPoolExecutor类的构造参数非常相似，这里不作解析 。

2.2.使用异步任务

使用方法，只要在目标方法的签名加上@Async

然而，执行结果却出乎意外（在main主线程上执行，没有异步执行）

熟悉springaop机制的同学，马上知道这是因为异步任务底层是基于动态代理机制实现的。Spring AOP 代理只有在通过 Spring 容器获取 Bean 时才会创建。当在同一个类内部调用一个方法时，调用的是原始对象，而不是代理对象。因此，内部调用不会经过 Spring AOP 代理，也就无法触发异步执行。解决这个问题最简单的方法是用一个新的类来管理异步执行方法。

问题解决

2.3.模拟系统繁忙进行性能测试

我们尝试模拟一些极端情况，系统处理不过来的情况。修改上面的配置，改为

pool:coreSize: 1queueCapacity: 1maxSize: 8

同时，异步执行增加时间延迟来模拟耗时任务

@Component
@Slf4j
class AsyncTaskHandler {@Asyncpublic void busyTask1() {try {Thread.sleep(5000);} catch (InterruptedException ignored) {}log.info("----------busyTask1---------");}@Asyncpublic void busyTask2() {try {Thread.sleep(5000);} catch (InterruptedException ignored) {}log.info("----------busyTask2---------");}}

执行结果会出现报错（线程数已达到最大数量，且任务队列已满，无法添加新任务）

 调度任务执行频率是可预见的，有多少个任务，执行频率，开发可知，核心数量，最大数量，队列容量比较好设定。而异步执行频率很大程度是由系统的使用者（用户）决定的，因此这些参数需要根据流量动态修改。

2.4.异步线程池拒绝策略

如果不想把  queueCapacity和maxSize都设置成很大的话，我们可以考虑修改下线程池的拒绝策略。最妥当的方式是，既然异步不了，那就"熔断"成同步，直接在调用者所在的业务线程执行。然而，springboot没有提供相应的配置项。为此，我们只能关闭springboot的自动配置了。 

从代码可看出，只要提供一个Executor实例，并且名字叫taskExecutor即可。

话不多说，上代码

@Configuration
public class ThreadPoolConfig {private final int core = Runtime.getRuntime().availableProcessors();/*** springboot 自动注入的异步执行线程池，拒绝策略为丢弃，难以配置maxPoolSize参数* @see TaskExecutionAutoConfiguration#taskExecutorBuilder*/@Bean(name = "taskExecutor")public ThreadPoolTaskExecutor threadPoolTaskExecutor(TaskExecutionProperties properties) {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(properties.getPool().getCoreSize());executor.setThreadNamePrefix(properties.getThreadNamePrefix());executor.setMaxPoolSize(properties.getPool().getMaxSize());executor.setQueueCapacity(properties.getPool().getQueueCapacity());executor.setKeepAliveSeconds((int) properties.getPool().getKeepAlive().toSeconds());executor.setAllowCoreThreadTimeOut(properties.getPool().isAllowCoreThreadTimeout());// 超过队列容量，则在业务线程上执行executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());return executor;}}

重新运行程序，可以看到，当任务超过线程池负载的时候，多余的线程会在调用线程上执行，变为同步代码

个人认为：使用springboot创建的线程池，代码也只是稍微简化一点点。

采用原生线程池，每个业务代码必须实现Runnable接口，而使用springboot的异步线程池，只需以方法注解的形式即可，底层aop会生成对应的代理方法。但要确保避免内部方法调用导致异步逻辑失效。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/437067.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

LeetCode[中等] 763. 划分字母区间

LeetCode[中等] 763. 划分字母区间

给你一个字符串 s 。我们要把这个字符串划分为尽可能多的片段&#xff0c;同一字母最多出现在一个片段中。 注意&#xff0c;划分结果需要满足&#xff1a;将所有划分结果按顺序连接&#xff0c;得到的字符串仍然是 s 。 返回一个表示每个字符串片段的长度的列表。 思路 贪心…
阅读更多...
使用默认不可变的Rust变量会踩什么坑

使用默认不可变的Rust变量会踩什么坑

讲动人的故事&#xff0c;写懂人的代码 Rust的变量真的是名不副实。名字中明明有个“变”字&#xff0c;却默认不可变。还美其名曰“不可变变量”。要想让变量名副其实&#xff0c;还必须费心额外加个mut关键字&#xff0c;并必须称其为“可变变量”&#xff0c;才能与前者区分…
阅读更多...
使用kaggle命令下载数据集和模型

使用kaggle命令下载数据集和模型

1、点击用户头像&#xff0c;点击Settings&#xff1a; 2、找到API&#xff0c;点击create new token&#xff0c;将自动下载kaggle.json&#xff1a; 3、在用户目录下创建.kaggle文件夹&#xff0c;并将下载的kaggle.json文件移动到该文件夹&#xff1a; cd ~ mv Downloads…
阅读更多...
负载均衡--相关面试题（六）

负载均衡--相关面试题（六）

在负载均衡的面试中&#xff0c;可能会遇到一系列涉及概念、原理、实践应用以及技术细节的问题。以下是一些常见的负载均衡面试题及其详细解答&#xff1a; 一、什么是负载均衡&#xff1f; 回答&#xff1a;负载均衡是一种将网络请求或数据传输工作分配给多个服务器或网络资源…
阅读更多...
编码能力提升计划 - 华为OD统一考试(E卷)

编码能力提升计划 - 华为OD统一考试(E卷)

2024华为OD机试（E卷+D卷+C卷）最新题库【超值优惠】Java/Python/C++合集 题目描述 为了提升软件编码能力，小王制定了刷题计划，他选了题库中的n道题，编号从0到n-1，并计划在m天内按照题目编号顺序刷完所有的题目(注意，小王不能用多天完成同一题)。 在小王刷题计划中，小王…
阅读更多...
计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-10-01

计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-10-01

计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-10-01 目录 文章目录 计算机前沿技术-人工智能算法-大语言模型-最新研究进展-2024-10-01目录1. Beyond Text-to-Text: An Overview of Multimodal and Generative Artificial Intelligence for Education Using Topi…
阅读更多...
QT-MySQL QSqlDatabase: QMYSQL driver not loaded

QT-MySQL QSqlDatabase: QMYSQL driver not loaded

文章目录 问题解决操作&#xff1a;自己尝试编译&#xff0c;各种错误层出不穷&#xff1a; 解决问题检查总结&#xff1a; 问题 使用Qt连接mysql数据库&#xff0c;遇到了一个问题&#xff0c;就是QT5.14.1版本在连接MySQL数据库时候&#xff0c;提示驱动加载失败&#xff0c…
阅读更多...
el-table添加fixed后错位问题

el-table添加fixed后错位问题

1 方案1 return {isShow:false, }mounted() {this.isShowtrue},watch: {$route(newRoute) {this.monitoredRoute newRoute; // 将新的路由信息保存到组件的monitoredRoute属性中// 执行其他操作或调用其他方法},//或$route(newRoute) {this.monitoredRoute newRoute; // 将新…
阅读更多...
AI 对话工具汇总

AI 对话工具汇总

&#x1f423;个人主页 可惜已不在 &#x1f424;这篇在这个专栏AI_可惜已不在的博客-CSDN博客 &#x1f425;有用的话就留下一个三连吧&#x1f63c; 目录 前言: 正文: 前言: 在科技飞速发展的时代&#xff0c;AI 对话正逐渐成为我们获取信息、交流思想的新方式。它以强…
阅读更多...
【系统代码】招投标采购一体化管理系统，JAVA+vue

【系统代码】招投标采购一体化管理系统，JAVA+vue

前言&#xff1a; 随着互联网和数字技术的不断发展&#xff0c;企业采购管理逐渐走向数字化和智能化。数字化采购平台作为企业采购管理的新模式&#xff0c;能够提高采购效率、降低采购成本、优化供应商合作效率&#xff0c;已成为企业实现效益提升的关键手段。系统获取在文末…
阅读更多...
MES（软件）系统是什么？MES系统为何如此重要呢？

MES（软件）系统是什么？MES系统为何如此重要呢？

一、MES系统的定义与功能 MES系统是一套面向制造企业车间执行层的生产信息化管理系统&#xff0c;它涵盖了多种功能模块&#xff0c;包括但不限于&#xff1a; 订单管理&#xff1a;处理客户订单&#xff0c;确保生产需求与市场需求相匹配。生产调度&#xff1a;根据订单和生…
阅读更多...
1.5 测试用例

1.5 测试用例

欢迎大家订阅【软件测试】 专栏&#xff0c;开启你的软件测试学习之旅&#xff01; 文章目录 前言1 测试用例介绍2 测试用例编写3 案例分析4 执行测试用例 前言 测试用例的设计和编制是软件活动中最重要的工作。本文详细讲解了测试用例的基本概念以及如何编写测试用例。 本篇文…
阅读更多...
React 解释常见的 hooks: useState / useRef / useContext / useReducer

React 解释常见的 hooks: useState / useRef / useContext / useReducer

前言 如果对 re-render 概念还不清楚&#xff0c;建议先看 React & 理解 re-render 的作用、概念&#xff0c;并提供详细的例子解释 再回头看本文。 如果对 React 基础语法还不熟练&#xff0c;建议先看 React & JSX 日常用法与基本原则 再回头看本文。 useState useS…
阅读更多...
51单片机系列-串口（UART）通信技术

51单片机系列-串口（UART）通信技术

&#x1f308;个人主页&#xff1a; 羽晨同学 &#x1f4ab;个人格言:“成为自己未来的主人~” 并行通信和串行通信 并行方式 并行方式&#xff1a;数据的各位用多条数据线同时发送或者同时接收 并行通信特点&#xff1a;传送速度快&#xff0c;但因需要多根传输线&#xf…
阅读更多...
监控易监测对象及指标之：全面监控Sybase_New数据库

监控易监测对象及指标之：全面监控Sybase_New数据库

随着企业数据量的不断增长和业务的复杂化&#xff0c;数据库的稳定性和性能成为了保障业务连续性的关键因素。Sybase_New数据库作为众多企业选择的数据管理解决方案&#xff0c;其稳定性和性能对于企业的运营至关重要。 为了确保Sybase_New数据库的稳定运行和高效性能&#xff…
阅读更多...
【Golang】深入解读Go语言中的错误（error）与异常（panic）

【Golang】深入解读Go语言中的错误（error）与异常（panic）

✨✨ 欢迎大家来到景天科技苑✨✨ &#x1f388;&#x1f388; 养成好习惯&#xff0c;先赞后看哦~&#x1f388;&#x1f388; &#x1f3c6; 作者简介&#xff1a;景天科技苑 &#x1f3c6;《头衔》&#xff1a;大厂架构师&#xff0c;华为云开发者社区专家博主&#xff0c;…
阅读更多...
蓝桥杯—STM32G431RBT6(IIC通信--EEPROM(AT24C02)存储器进行通信)

蓝桥杯—STM32G431RBT6(IIC通信--EEPROM(AT24C02)存储器进行通信)

一、什么是IIC&#xff1f;24C02存储器有什么用&#xff1f; IIC &#xff08;IIC 是半双工通信总线。半双工意味着数据在某一时刻只能沿一个方向传输&#xff0c;即发送数据的时候不能接收数据&#xff0c;接收数据的时候不能发送数据&#xff09;即集成电路总线&#xff08;…
阅读更多...
AI智能时代的图书馆未来，你想象过吗！

AI智能时代的图书馆未来，你想象过吗！

AI智能时代的图书馆未来&#xff0c;你想象过吗&#xff01; 前言AI智能时代的图书馆未来 前言 教育数字化和 AI 时代的浪潮正汹涌而来&#xff0c;图书馆也站在了变革的十字路口。我们看到高等教育正在发生深刻的变革&#xff0c;从教学模式到人才培养理念&#xff0c;都在经…
阅读更多...
Linux 再入门整理：详解 /etc/fstab 文件

Linux 再入门整理：详解 /etc/fstab 文件

目录 1. 什么是 /etc/fstab2. /etc/fstab 文件的格式2.1 设备文件 (Device)2.2 挂载点 (Mount Point)2.3 文件系统类型 (File System Type)2.4 挂载选项 (Mount Options)2.5 Backup Operation&#xff08;dump 参数&#xff09;2.6 Pass Order (fsck 参数)2.6.1 参数设置2.6.2 …
阅读更多...
智慧防灾，科技先行：EasyCVR平台助力地质灾害视频监测系统建设

智慧防灾，科技先行：EasyCVR平台助力地质灾害视频监测系统建设

随着科技的飞速发展&#xff0c;视频监控技术已成为地质灾害监测与预警的重要手段之一。在众多视频监控平台中&#xff0c;EasyCVR视频汇聚平台凭借其强大的视频整合、实时传输、视频处理及分发等能力&#xff0c;在地质灾害场景中展现出显著的应用优势。 一、实时监测与远程监…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023