定时任务时间过长会不会影响下次的执行?- 第331篇

前言

       有关定时任务会不会延迟执行了,可以看文章《为什么你要阻碍我,你看我扎不扎你「见鬼,定时任务延迟执行?」 - 第292篇》

https://mp.weixin.qq.com/s/G1-92E7jvvy5Ngp7nIIykg

       本质上来讲,我们这一篇文章的问题的答案在上一篇已经算是给出了答案了,只是没有那么明确,这一节我们来明确的说一下。

       针对这个问题「定时任务时间过长会不会影响下次的执行」,也是考虑定时任务是单线程的还是多线程的。

一、单线程

       有这么一个定时任务:

  1. @Scheduled(cron="10 * * * * ? ")
  2. public void aTask(){
  3. DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  4. System.out.println(Thread.currentThread().getName()+":" +sdf.format(new Date())+" --> A任务每10秒执行一次");
  5. try {
  6. TimeUnit.SECONDS.sleep(70);
  7. } catch (InterruptedException e) {
  8. e.printStackTrace();
  9. }
  10. }

如果按照我们的想像的情况下,现在8:00:00的话,那么8:00:10的时候执行第一次,8:01:10的时候执行第二次,以此类推,但是在单线程的情况下却不是这样子执行的,当让我们的定时任务执行过长超过了下一次要执行的时候,那么就需要等到下一次才能执行了,我们看下执行的情况:

scheduling-1:2020-09-28 20:02:10--> A任务每10秒执行一次

scheduling-1:2020-09-28 20:04:10--> A任务每10秒执行一次

scheduling-1:2020-09-28 20:06:10--> A任务每10秒执行一次

       中间总是会隔了1分钟。

 

二、多线程

       如何开启多线程还不懂嘛,那么请阅读《为什么你要阻碍我,你看我扎不扎你「见鬼,定时任务延迟执行?」 - 第292篇》。

       在多线程情况下,结果是什么样子呢?我们还是直接看下控制塔的打印在来给出结果吧:

myThread-1:2020-09-28 20:09:10--> A任务每10秒执行一次

myThread-1:2020-09-28 20:11:10--> A任务每10秒执行一次

       从这里我们可以看出多线程情况下还是有影响的。

 

三、异步任务

如何在定时任务中使用异步任务还不懂嘛,那么请阅读《为什么你要阻碍我,你看我扎不扎你「见鬼,定时任务延迟执行?」 - 第292篇》。

       在异步任务的情况下,我们看下结果:

task-1:2020-09-28 20:13:10 -->A任务每10秒执行一次

task-2:2020-09-28 20:14:10 -->A任务每10秒执行一次

       从这里我们可以看出在异步任务的情况下,就不会延迟了,从上面的打印我们可以看出是不同的任务在执行下一次的定时任务。即使上一个任务还没执行完成也不影响下一次的执行了。

 



四、多线程定时任务执行时间过长的思考

       这里我们主要是针对开启了多线程的情况下,单线程为啥不考虑呐。

我们在文章《为什么你要阻碍我,你看我扎不扎你「见鬼,定时任务延迟执行?」 - 第292篇》中说明,如果有两个任务A和B,如果A执行过长的话是会影响B的执行的。

那么在实际项目中,我们肯定不希望A的执行影响到B的执行了。所以正常情况下都会开启多线程的支持的。

在接下来的讨论都是基于多线程开启的情况下的定时任务的思考。

4.1 同一个定时任务执行时间过长会影响下一次的执行吗?

       这个我们在前面分析了,答案是会有影响的,那么如何解决这个问题呐?

       有两种思路:①使用异步任务,使用@Async即可。②使用线程,将耗时的代码放到线程的run方法中进行执行。

①使用异步任务,使用@Async即可

  1. @Scheduled(cron="10 * * * * ? ")
  2. @Async //使用异步任务,使用@Async即可
  3. public void aTask(){
  4. DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  5. System.out.println(Thread.currentThread().getName()+":" +sdf.format(new Date())+" --> A任务每10秒执行一次");
  6. try {
  7. TimeUnit.SECONDS.sleep(70);
  8. } catch (InterruptedException e) {
  9. e.printStackTrace();
  10. }
  11. }

②使用线程,将耗时的代码放到线程的run方法中进行执行。

  1. @Scheduled(cron="10 * * * * ? ")
  2. public void aTask(){
  3. new Thread() {
  4. public void run() {
  5. DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  6. System.out.println(Thread.currentThread().getName()+":" +sdf.format(new Date())+" --> A任务每10秒执行一次");
  7. try {
  8. TimeUnit.SECONDS.sleep(70);
  9. } catch (InterruptedException e) {
  10. e.printStackTrace();
  11. }
  12. };
  13. }.start();
  14. }

4.2 不同定时任务会互相影响吗?

       这个是不会影响的,我们在之前的文章中已经说明过了,这里不重复进行说明了。

4.3 重复执行问题如何解决?

       如果我们解决了定时任务执行过长影响下一次执行的问题,也就是能够根据设置的表达式进行定时执行了,那么又会可能产生什么新的问题呢?就是定时任务重复执行的问题

       一般我们的定时任务都会查库然后进行操作的,如果此时上一个定时任务未执行完成,下次的定时任务又开始了,那么很有可能会获取到重复的数据。那么定时任务就会被重复执行了。

       这里提供两种思路进行解决吧:

(1)锁表行记录:如果这表就是一个定时任务的表的话,那么可以将表行记录进行锁住。如果不是定时任务的表,是其它业务表的话,锁表行记录就不可行了。

(2)缓存id:我们一般获取到的数据都是有id的,那么我们可以将当前正在处理的id缓存起来,如果下个任务进来了,发现此id已经在缓存中,说明这个id已经正在定时任务中进行处理了,直接舍此id,进行下个id即可。。

 

4.4不同的任务类中的定时任务方法也会互相影响吗(单线程下)

会相互影响的,Spring单线程的话,会管理所有的定时任务的,和是否是不是一个类定义的定时任务没有关系。

测试结果如下(MyTask1和MyTask2):

scheduling-1:2020-07-02 15:04:25--> B任务每5秒执行一次

scheduling-1:2020-07-02 15:04:30--> A任务每10秒执行一次

scheduling-1:2020-07-02 15:04:50--> B任务每5秒执行一次

scheduling-1:2020-07-02 15:04:55--> B任务每5秒执行一次

我们会发现在默认配置单线程的情况下,B任务收到影响了,一旦A任务执行的话,B任务就会延迟执行了。


购买完整视频,请前往:http://www.mark-to-win.com/TeacherV2.html?id=287