Spring boot如何通过@Scheduled实现定时任务及多线程配置

更新时间：2019年12月02日 10:09:09 作者：慕尘

这篇文章主要介绍了Spring boot如何通过@Scheduled实现定时任务及多线程配置,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

使用@Scheduled 可以很容易实现定时任务

spring boot的版本 2.1.6.RELEASE

package com.abc.demo.common;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.concurrent.TimeUnit;
@EnableScheduling
@Component
public class ScheduleSetting {
  private final Logger logger = LoggerFactory.getLogger(Tasks.class);
  @Scheduled(fixedRate = 10000, initialDelay = 2000)
  public void scheduleRead() {
    try {
      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron1任务开始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      long endStamp = System.currentTimeMillis();
      try {
        TimeUnit.SECONDS.sleep(20);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("cron1任务正在运行的线程名称：" + thread.getName() + " 结束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("++++++++++++++++++++++++");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }

  @Scheduled(fixedRate = 5000, initialDelay = 1000)
  public void scheduleConvert() {
    try {

      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron2任务开始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      try {
        TimeUnit.SECONDS.sleep(10);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      long endStamp = System.currentTimeMillis();
      System.out.println("cron2任务正在运行的线程名称：" + thread.getName() + " 结束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("====================");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }
}

运行输出内容为

cron2任务开始,start=2019-10-11 17:31:52, threadId=34, threadName=scheduling-1
cron2任务正在运行的线程名称：scheduling-1 结束,start=2019-10-11 17:31:52,end=2019-10-11 17:32:02
====================
cron1任务开始,start=2019-10-11 17:32:02, threadId=34, threadName=scheduling-1
cron1任务正在运行的线程名称：scheduling-1 结束,start=2019-10-11 17:32:02,end=2019-10-11 17:32:02
++++++++++++++++++++++++
cron2任务开始,start=2019-10-11 17:32:22, threadId=34, threadName=scheduling-1
cron2任务正在运行的线程名称：scheduling-1 结束,start=2019-10-11 17:32:22,end=2019-10-11 17:32:32

……

注：

　　cron2执行完后才会执行cron1

原因：

　　spring默认是以单线程执行任务调度

　　spring的定时任务默认最大运行线程数为1，多个任务执行起来时间会有问题

1.配置线程池

在配置文件application.properties中添加

# 线程池大小
spring.task.scheduling.pool.size=5
# 线程名前缀
spring.task.scheduling.thread-name-prefix=myScheduling-

输出内容变为

cron2任务开始,start=2019-10-11 17:34:48, threadId=34, threadName=myScheduling-1
cron1任务开始,start=2019-10-11 17:34:49, threadId=35, threadName=myScheduling-2
cron2任务正在运行的线程名称：myScheduling-1 结束,start=2019-10-11 17:34:48,end=2019-10-11 17:34:58
====================
cron2任务开始,start=2019-10-11 17:34:58, threadId=34, threadName=myScheduling-1
cron2任务正在运行的线程名称：myScheduling-1 结束,start=2019-10-11 17:34:58,end=2019-10-11 17:35:08
====================
cron2任务开始,start=2019-10-11 17:35:08, threadId=57, threadName=myScheduling-3
cron1任务正在运行的线程名称：myScheduling-2 结束,start=2019-10-11 17:34:49,end=2019-10-11 17:34:49

……

注：

多线程下，cron1和cron2不用互相等待了，但是同一个任务还是需要等待的

2.并发

修改代码

package com.abc.demo.common;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.concurrent.TimeUnit;
@EnableScheduling
@Component
@EnableAsync
public class ScheduleSetting {
  private final Logger logger = LoggerFactory.getLogger(Tasks.class);
  @Async
  @Scheduled(fixedRate = 10000, initialDelay = 2000)
  public void scheduleRead() {
    try {
      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron1任务开始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      long endStamp = System.currentTimeMillis();
      try {
        TimeUnit.SECONDS.sleep(20);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("cron1任务正在运行的线程名称：" + thread.getName() + " 结束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("++++++++++++++++++++++++");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }

  @Async
  @Scheduled(fixedRate = 5000, initialDelay = 1000)
  public void scheduleConvert() {
    try {

      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron2任务开始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      try {
        TimeUnit.SECONDS.sleep(10);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      long endStamp = System.currentTimeMillis();
      System.out.println("cron2任务正在运行的线程名称：" + thread.getName() + " 结束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("====================");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }
}

输出的内容

cron2任务开始,start=2019-10-11 17:39:53, threadId=57, threadName=task-1
cron1任务开始,start=2019-10-11 17:39:54, threadId=59, threadName=task-2
cron2任务开始,start=2019-10-11 17:39:58, threadId=61, threadName=task-3
cron2任务开始,start=2019-10-11 17:40:03, threadId=63, threadName=task-4
cron2任务正在运行的线程名称：task-1 结束,start=2019-10-11 17:39:53,end=2019-10-11 17:40:03
====================
cron1任务开始,start=2019-10-11 17:40:04, threadId=64, threadName=task-5
cron2任务开始,start=2019-10-11 17:40:08, threadId=65, threadName=task-6
cron2任务正在运行的线程名称：task-3 结束,start=2019-10-11 17:39:58,end=2019-10-11 17:40:08
====================
cron2任务开始,start=2019-10-11 17:40:13, threadId=66, threadName=task-7
cron2任务正在运行的线程名称：task-4 结束,start=2019-10-11 17:40:03,end=2019-10-11 17:40:13
====================
cron1任务正在运行的线程名称：task-2 结束,start=2019-10-11 17:39:54,end=2019-10-11 17:39:54

说明：　

　　@EnableAsync开启多线程
　　@Async标记其为一个异步任务
　　每个定时任务都是在通过不同的线程来处理，线程名的前缀成了task-
　　线程默认为10个

修改配置

spring.task.execution.thread-name-prefix=mytask-
spring.task.execution.pool.core-size=5

重新运行的输出

cron2任务开始,start=2019-10-11 17:44:00, threadId=56, threadName=mytask-1
cron1任务开始,start=2019-10-11 17:44:01, threadId=57, threadName=mytask-2
cron2任务开始,start=2019-10-11 17:44:05, threadId=58, threadName=mytask-3
cron2任务开始,start=2019-10-11 17:44:10, threadId=59, threadName=mytask-4
cron2任务正在运行的线程名称：mytask-1 结束,start=2019-10-11 17:44:00,end=2019-10-11 17:44:10
====================
cron1任务开始,start=2019-10-11 17:44:11, threadId=60, threadName=mytask-5
cron2任务正在运行的线程名称：mytask-3 结束,start=2019-10-11 17:44:05,end=2019-10-11 17:44:15
====================
cron2任务开始,start=2019-10-11 17:44:15, threadId=58, threadName=mytask-3
cron2任务开始,start=2019-10-11 17:44:20, threadId=56, threadName=mytask-1
cron2任务正在运行的线程名称：mytask-4 结束,start=2019-10-11 17:44:10,end=2019-10-11 17:44:20
====================
cron1任务正在运行的线程名称：mytask-2 结束,start=2019-10-11 17:44:01,end=2019-10-11 17:44:01

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

浅谈Java三大框架与应用
这篇文章主要介绍了浅谈Java三大框架与应用,需要的朋友可以参考下
2015-05-05
Java 进程执行外部程序造成阻塞的一种原因
前一阵子在研究文档展示时使用了java进程直接调用外部程序,其中遇到一个问题花了好长时间才解决,这个问题就是外部程序直接执行没什么问题，但是当使用Java进程执行时外部程序就阻塞在那儿不动了。而且这个外部程序在处理某些文件时使用Java进程执行是没问题的
2014-03-03
全局记录Feign的请求和响应日志方式
这篇文章主要介绍了全局记录Feign的请求和响应日志方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-06-06
图解Java ReentrantLock公平锁和非公平锁的实现
ReentrantLock是Java并发中十分常用的一个类，具备类似synchronized锁的作用。但是相比synchronized, 它具备更强的能力，同时支持公平锁和非公平锁。本文就来聊聊ReentrantLock公平锁和非公平锁的实现，需要的可以参考一下
2022-10-10
Springboot获取前端反馈信息并存入数据库的实现代码
这篇文章主要介绍了Springboot获取前端反馈信息并存入数据库的实现代码,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-03-03
Mybatis日志参数快速替换占位符工具的详细步骤
这篇文章主要介绍了Mybatis日志参数快速替换占位符工具的详细步骤，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2020-08-08
Java多线程实现简易微信发红包的方法实例
这篇文章主要给大家介绍了关于Java多线程实现简易微信发红包的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-01-01
详谈java编码互转(application/x-www-form-urlencoded)
下面小编就为大家带来一篇详谈java编码互转(application/x-www-form-urlencoded)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-07-07
SpringBoot中操作Bean的生命周期的方法总结
在SpringBoot应用中,管理和操作Bean的生命周期是一项关键的任务,这不仅涉及到如何创建和销毁Bean,还包括如何在应用的生命周期中对Bean进行精细控制,本文给大家总结了SpringBoot中操作Bean的生命周期的方法,需要的朋友可以参考下
2023-12-12
彻底解决Spring mvc中时间的转换和序列化等问题
这篇文章主要介绍了彻底解决Spring mvc中时间的转换和序列化等问题，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2019-09-09