Spring定时任务高级使用篇

dcr309duan 发布于2019-08-19 10:53 / 2155人阅读

摘要：定时任务高级使用篇前面一篇博文之定时任务基本使用篇介绍了环境下，定时任务的简单使用姿势，也留了一些问题，这一篇则希望能针对这些问题给个答案定时任务进阶篇问题小结前面一篇博文，抛出了下面的几个问题，接下来则围绕问题进行分析一个项目中有多个定时

Spring定时任务高级使用篇

前面一篇博文《Spring之定时任务基本使用篇》介绍了Spring环境下，定时任务的简单使用姿势，也留了一些问题，这一篇则希望能针对这些问题给个答案

I. 定时任务进阶篇 1. 问题小结

前面一篇博文，抛出了下面的几个问题，接下来则围绕问题进行分析

一个项目中有多个定时任务时，他们是并行执行的还是串行执行的？

如果默认是串行的

那么有相同的crond表达式的定时任务之间，有先后顺序么？

某个任务的阻塞是否会影响后面的任务？

如果需要他们并行执行，可以怎么做？

如果是并发执行的

是新创建线程还是采用线程池来复用呢？

在并发执行时，假设有个每秒执行一次的任务，但是它执行一次消耗的时间大于1s时，这个任务的表现时怎样的呢？不断地新增线程来执行还是等执行完毕之后再执行下一次的呢?

2. 多定时任务的串并行分析

如何确认一个项目中的多个定时任务是串行执行还是并发执行呢？要想验证这个功能，最好的法子就是写个testcase，比如定义两个定时任务，在其中一个任务中写个死循环，看另外一个任务是否会正常执行

@Scheduled(cron = "0/1 * * * * ?")
public void sc1() throws InterruptedException {
    System.out.println(Thread.currentThread().getName() + " | sc1 " + System.currentTimeMillis());
    while (true) {
        Thread.sleep(5000);
    }
}

@Scheduled(cron = "0/1 * * * * ?")
public void sc2() {
    System.out.println(Thread.currentThread().getName() + " | sc2 " + System.currentTimeMillis());
}

首先我们分析的是 sc1和sc2这两个任务的执行是串行还是并行的，暂时先不考虑 sc1 调用时阻塞，下一秒是否是开新的线程再调用sc1

若串行：则sc1打印一次，sc2可能打印0或者1次

若并行：sc1打印一次，sc2打印n多次

实际运行，GIF图演示如下

上图的结果，印证了默认的情况下，多个定时任务时串行执行的；如果一个任务出现阻塞，其他的任务都会受到影响

3. 定时任务执行的优先级

既然是顺序执行的，那么优先级怎么定？每次都是固定的，还是随机的呢？

要验证上面的方法，也容易，同样两个任务，看他们的输出是否会乱掉，如果每次都是任务1打印完再打印任务2，那就是固定优先级的；否则每次调度时，顺序不好说

测试代码如下

@Scheduled(cron = "0/1 * * * * ?")
public void sc1()  {
    System.out.println(Thread.currentThread().getName() + " | sc1 " + System.currentTimeMillis());
}

@Scheduled(cron = "0/1 * * * * ?")
public void sc2() {
    System.out.println(Thread.currentThread().getName() + " | sc2 " + System.currentTimeMillis());
}

实测结果如下

从输出得出结论：顺序是串掉的，并没有表现出明显的优先级关系

4. 并行调度

接下来的问题就是我希望这些任务可以并发执行，可以实现么？

当然是可以，用起来也比较简单，首先是在Application上添加注解@EnableAsync，开启异步调用，然后再计划任务上加上@Async注解即可，一个简单的demo如下

@EnableAsync
@EnableScheduling
@SpringBootApplication
public class QuickMediaApplication {

    public static void main(String[] args) {
        SpringApplication.run(QuickMediaApplication.class, args);
    }

    @Scheduled(cron = "0/1 * * * * ?")
    @Async
    public void sc1()  {
        System.out.println(Thread.currentThread().getName() + " | sc1 " + System.currentTimeMillis());
    }
}

上面执行之后，查看输出（异步调度时，理论上线程名应该不一样)

从上面的输出，可以简单的推理，每次调度上面的任务都是新开了一个线程来做的，所以如果在定时任务中写了死循环，是否会导致无限线程，最后整个进程崩掉？

额外提一句，linux系统下单进程的线程数是有上线的，查看命令为：

ulimit -u

在测试之前，先看下上面的正常任务执行，如下面的动图，线程数并没有夸张的长法

接下来换成死循环的调度方式，实际测试如下，线程数蹭蹭的上涨

所以使用默认的异步调用方式，并不是一个好注意，说不准就被玩死了自己都不知道，那么可以用自己的线程池来管理这些异步任务么？

5. 自定义线程池

用自定义的线程池来取代默认线程管理方式，无疑是一个更加安全和灵活的方式，使用起来也并不麻烦，和平常创建线程池的套路没什么区别，要在Spring生态中使用，就把它搞成bean即可

直接借助Spring的线程池ThreadPoolTaskExecutor

@Bean
public AsyncTaskExecutor asyncTaskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setThreadNamePrefix("yhh-schedule-");
    executor.setMaxPoolSize(10);
    executor.setCorePoolSize(3);
    executor.setQueueCapacity(0);
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
    return executor;
}

@Scheduled(cron = "0/1 * * * * ?")
@Async
public void sc1() throws InterruptedException {
    System.out.println(Thread.currentThread().getName() + " | sc1 " + System.currentTimeMillis());
    while (true) {
        Thread.sleep(1000 * 5);
    }
}

实际演示的结果如下，最多10个线程，再提交的任务直接丢弃

简单说一下，用自定义线程池的好处:

合理的分配线程池参数

拒绝策略的选择也比较有意思（可以按照自己的想法来处理"负载"的任务）

线程池命名，对于以后问题排查，会有很大的帮助

6. 小结

本来这篇博文在昨天即8月2号就应该写完的，结果晚上生产环境下除了点问题，解决线上故障之后就比较晚了，留到了今天，哎，拖延症也是要不得。。。

下面小结Spring中定时任务的几个知识点

默认所有的定时任务都是串行调度的，一个线程，且即便crond完全相同的两个任务先后顺序也没法保证（具体原因需要源码分析，看下这块是怎么支持）

使用@Async注解可以使定时任务异步调度；但是需要开启配置，在启动类上添加 @EnableAsync 注解

开启并发执行时，推荐用自定义的线程池来替代默认的，理由见上面

II. 其他 0. 相关

《Spring之定时任务基本使用篇》

1. 一灰灰Blog： https://liuyueyi.github.io/he...

一灰灰的个人博客，记录所有学习和工作中的博文，欢迎大家前去逛逛

2. 声明

尽信书则不如，已上内容，纯属一家之言，因个人能力有限，难免有疏漏和错误之处，如发现bug或者有更好的建议，欢迎批评指正，不吝感激

微博地址: 小灰灰Blog

QQ：一灰灰/3302797840

3. 扫描关注

小灰灰Blog&公众号

知识星球

服务器托管混合云高级篇定时任务与触发任务定时任务实现定时任务

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/76625.html

Spring之定时任务基本使用篇

摘要：表示起始时间开始触发，然后每隔固定时间触发一次如在域使用则意味着分钟触发一次，而，等分别触发一次表示列出枚举值值。 showImg(https://segmentfault.com/img/remote/1460000015852353); 文章链接：https://liuyueyi.github.io/hexblog/2018/08/01/180801-Spring之定时任务基本使用...

Jingbin_ 2019-08-19 10:51 评论0 收藏0
Java 定时任务系列（2）-Spring 定时任务的几种实现

本文来自网络一些博客的整理（包括gong1208的博客 dary1715的博客） 1、简介这个系列介绍Spring框架实现定时任务的两种方式以及一些高级的用法，包括： 1、使用Quartz，这是一个功能比较强大的的调度器，可以让你的程序在指定时间执行，也可以按照某一个频度执行，配置起来稍显复杂，稍后会详细介绍。 2、Spring3.0以后自带的task，可以将它看成一个轻量级的Quartz，而且...

roadtogeek 2019-08-14 12:00 评论0 收藏0
SpringCloud（第 046 篇）注解式Schedule配置定时任务，不支持任务调度

摘要：当前时间打印当前时间定时任务触发，操作多个添加数据，事务中任一异常，都可以正常导致数据回滚。当前时间当前时间添加微服务启动类注解式配置定时任务，不支持任务调度。 SpringCloud（第 046 篇）注解式Schedule配置定时任务，不支持任务调度 - 一、大致介绍 1、很多时候我们需要隔一定的时间去执行某个任务，为了实现这样的需求通常最普通的方式就是利用多线程来实现； 2、但是有...

masturbator 2019-08-15 12:16 评论0 收藏0
Spring 定时任务

摘要：在定时器接口的方法中我们可以发现一个方法接受接口，而也是一个接口，抽象了触发任务执行的触发器。更常用的一个触发器是，它使用表达式指定何时执行任务。配置定时任务首先看看配置。配置提供了命名空间，让配置定时任务非常简单。本文参考自Spring官方文档 34. Task Execution and Scheduling。在程序中常常有定时任务的需求，例如每隔一周生成一次报表、每个月月末清...

justCoding 2019-08-14 17:50 评论0 收藏0
SpringCloud（第 009 篇）简单 Quartz 微服务，不支持分布式

摘要：添加任务成功运行任务名称添加定时任务服务定时任务服务。触发器计划列表添加测试任务类测试任务类被任务调度后执行该任务类。声明一个静态变量保存添加启动类简单微服务，不支持分布式。 SpringCloud（第 009 篇）简单 Quartz 微服务，不支持分布式 - 一、大致介绍 1、本章节仅仅只是为了测试 Quartz 在微服务中的使用情况； 2、其实若只是简单的实现任务调用而言的话，Sp...

awkj 2019-08-16 10:47 评论0 收藏0