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

这篇文章主要介绍了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

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

(0)

相关推荐

  • 详解Spring Boot中使用@Scheduled创建定时任务

    我们在编写Spring Boot应用中经常会遇到这样的场景,比如:我需要定时地发送一些短信.邮件之类的操作,也可能会定时地检查和监控一些标志.参数等. 创建定时任务 在Spring Boot中编写定时任务是非常简单的事,下面通过实例介绍如何在Spring Boot中创建定时任务,实现每过5秒输出一下当前时间. 在Spring Boot的主类中加入@EnableScheduling注解,启用定时任务的配置 @SpringBootApplication @EnableScheduling publi

  • 详解SpringBoot开发案例之整合定时任务(Scheduled)

    来来来小伙伴们,基于上篇的邮件服务,定时任务就不单独分项目了,天然整合进了邮件服务中. 不知道,大家在工作之中,经常会用到那些定时任务去执行特定的业务,这里列举一下我在工作中曾经使用到的几种实现. 任务介绍 Java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务.Timer的优点在于简单易用:缺点是Timer的所有任务都是由同一个线程调度的,因此所有任务都是串行执行的.同一时间只能有一个任务在执行,前一个任务的延迟或异常都将会影响到之后的任

  • Java自带定时任务ScheduledThreadPoolExecutor实现定时器和延时加载功能

    java.util.concurrent.ScheduledThreadPoolExecutor 是JDK1 .6之后自带的包,功能强大,能实现定时器和延时加载的功能 各类功能和处理方面优于Timer 1.定时器: ScheduledThreadPoolExecutor  有个scheduleAtFixedRate(command, initialDelay, period, unit) ;方法 command: 执行的线程(可自己New一个) initialDelay:初始化执行的延时时间 p

  • spring-boot通过@Scheduled配置定时任务及定时任务@Scheduled注解的方法

    串行的定时任务 @Component public class ScheduledTimer { private Logger logger = Logger.getLogger(this.getClass()); /** * 定时任务,1分钟执行1次,更新潜在客户超时客户共享状态 */ @Scheduled(cron="0 0/1 8-20 * * ?") public void executeUpdateCuTask() { Thread current = Thread.curr

  • springboot 定时任务@Scheduled实现解析

    这篇文章主要介绍了springboot 定时任务@Scheduled实现解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 1.pom.xml中导入必要的依赖: <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version&g

  • ScheduledExecutorService任务定时代码示例

    本文主要分享了一则关于ScheduledExecutorService任务定时的实例代码,具体如下: 示例代码 package com.effective.common.concurrent.execute; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.concurre

  • Spring中@Scheduled和HttpClient的连环坑

    前言 本文主要给大家介绍了关于Spring中@Scheduled和HttpClient的坑,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧. 曾经踩过一个大坑: 由于业务特殊性,会定时跑很多定时任务,对业务数据进行补偿操作等. 在Spring使用过程中,我们可以使用@Scheduled注解可以方便的实现定时任务. 有一天早上突然发现,从前一天晚上某一时刻开始,所有的定时任务全部都卡死不再运行了. @Scheduled默认单线程 经排查后发现,我们使用@Scheduled注解默认的

  • Springboot通过Scheduled实现定时任务代码

    定时任务一般会存在中大型企业级项目中,为了减少服务器.数据库的压力往往会采用时间段性的去完成某些业务逻辑.比较常见的就是金融服务系统推送回调,一般支付系统订单在没有收到成功的回调返回内容时会持续性的回调,这种回调一般都是定时任务来完成的.还有就是报表的生成,我们一般会在客户访问量过小的时候来完成这个操作,那往往都是在凌晨.这时我们也可以采用定时任务来完成逻辑.SpringBoot为我们内置了定时任务,我们只需要一个注解就可以开启定时为我们所用了. 在开发中,定时任务是常见的功能,在spring

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

    这篇文章主要介绍了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.spr

  • Spring boot 打jar包分离lib的正确配置方式

    前言 Springboot 打jar包分离lib,配置文件的方式,网上可以搜到的我都没试通.跟刘大神(大神没有博客,很可惜)讨论后,给出了这么一个解决方案,供大家参考. 部署环境 window 10 redhat 6.4 其他版本没有尝试,应该也是可以的 POM.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.

  • spring boot线上日志级别动态调整的配置步骤

    目录 前言 正文 springboot版本:1.5.7 配置 文末结语 前言 日志模块是每个项目中必须的,用来记录程序运行中的相关信息.一般在开发环境下使用DEBUG级别的日志输出,为了方便查看问题,而在线上一般都使用INFO级别的日志,主要记录业务操作的日志.那么问题来了,当线上环境出现问题希望输出DEBUG日志信息辅助排查的时候怎么办呢?修改配置文件,重新打包然后上传重启线上环境,之前确实是这么做的.下面会介绍使用动态调整线上日志级别来解决这个问题. 正文 spring boot版本:1.5

  • spring boot task实现动态创建定时任务的方法

    在Spring Boot项目中,通过@EnableScheduling可启用Spring自带的定时任务支持,在通过@Scheduled注解定义定时任务,但是通过注解只能编写固定时间的定时任务,无法动态调整定时间隔,可通过实现SchedulingConfigurer接口实现动态定时任务注册. 对比Quartz的优缺点 优点:配置非常简单 缺点: 不支持分布式部署 不支持动态配置定时任务 不支持持久化 其实这几个缺点归根结底都是因为不支持持久化,所以如果项目需要持久化定时任务,还是要选择Quartz

  • 基于Spring Boot的Environment源码理解实现分散配置详解

    前提 org.springframework.core.env.Environment是当前应用运行环境的公开接口,主要包括应用程序运行环境的两个关键方面:配置文件(profiles)和属性.Environment继承自接口PropertyResolver,而PropertyResolver提供了属性访问的相关方法.这篇文章从源码的角度分析Environment的存储容器和加载流程,然后基于源码的理解给出一个生产级别的扩展. 本文较长,请用一个舒服的姿势阅读. Environment类体系 Pr

  • 详解Spring Boot 中实现定时任务的两种方式

    在 Spring + SpringMVC 环境中,一般来说,要实现定时任务,我们有两中方案,一种是使用 Spring 自带的定时任务处理器 @Scheduled 注解,另一种就是使用第三方框架 Quartz ,Spring Boot 源自 Spring+SpringMVC ,因此天然具备这两个 Spring 中的定时任务实现策略,当然也支持 Quartz,本文我们就来看下 Spring Boot 中两种定时任务的实现方式. @Scheduled 使用 @Scheduled 非常容易,直接创建一个

  • Spring Boot Admin 的使用详解

    一.前言 Spring Boot Admin 用于监控基于 Spring Boot 的应用.官方文档在这里(v1.3.4):<Spring Boot Admin Reference Guide> 实践的过程中,感觉这个 User Guide 结构上还是说的不太明白.所以我就大概写一遍我的实践过程与理解. 阅读此文前提条件是: 使用过 Maven. 你跑过基于 Spring Boot 的 hello world 程序. 第三节需要你会点 Spring Cloud 的 Eureka Server

  • Spring Boot Admin 添加报警提醒和登录验证功能的具体实现

    目录 1.添加报警提醒功能 1.1 添加邮件支持框架 1.2 配置收.发邮箱信息 1.2.1 开启 SMTP 服务 1.2.2 生成授权码 1.3 邮件报警测试 1.4 注意事项 1.5 配置多个报警通知邮箱 2.访问权限设置 2.1 添加 Security 框架支持 2.2 设置登录账户 2.3 权限资源设置 2.4 访问 SBA 总结 Spring Boot Admin(SBA)是一个开源的社区项目,用于管理和监控 Spring Boot 应用程序,它提供了详细的健康信息.内存信息.JVM

  • Spring boot怎么整合Mybatis

    最近刚接触spring boot,正是因为他的及简配置方便开发,促使我下定决心要用它把之前写的项目重构,那么问题来了,spring boot怎么整合mybatis呢,下面几个配置类来搞定. 在我的代码当中是实现了数据库读写分离的,所以代码仅做参考,如有需要可以加我微信:benyzhous [后续更新] 1.文件结构 DataBaseConfiguration.Java用来获取数据库连接配置信息,配置从application.properties中读取 MybatisConfiguration.j

随机推荐