脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot Scheduling定时任务

SpringBoot使用Scheduling实现定时任务的示例代码

 更新时间：2023年08月13日 14:46:03   作者：palm down  
Spring Boot提供了一种方便的方式来实现定时任务,即使用Spring的@Scheduled注解,通过在方法上添加@Scheduled注解,我们可以指定方法在何时执行,本文我们就给大家介绍一下SpringBoot如何使用Scheduling实现定时任务,需要的朋友可以参考下

springboot实现定时任务

开启springboot定时任务

  • springboot实现定时任务很简单，只需要在启动类上加上 @EnableScheduling 就可以
/**
 * @author liouwb
 */
@SpringBootApplication
@EnableScheduling
public class SchedulerApplication{
    public static void main(String[] args) {
        SpringApplication.run(SchedulerApplication.class, args);
    }
}
  • 编写测试类
/**
 * @author liouwb
 */
@Slf4j
@Component
public class TestJob {
    /**
     * 定时任务-串行
     * 固定一秒执行一次
     *
     * @author liouwb
     */
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask1() {
        log.info("测试任务-1");
    }
}
  • 执行结果

在这里插入图片描述

  • 下面测试，如果让每次任务执行5秒
    /**
     * 定时任务-串行
     * 固定一秒执行一次
     *
     * @author liouwb
     */
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask1() throws InterruptedException {
        // 让每次任务执行5秒
        Thread.sleep(5 * 1000);
        log.info("测试任务-1");
    }
  • 想要的结果是1一秒执行一次
  • 实际执行结果，是6秒执行一次，线程串行执行
  • 未达到想要的接口

在这里插入图片描述

原因分析：

  • @EnableScheduling 注解默认使用的是 ThreadPoolTaskScheduler 线程池，默认线程数是1
  • 下面我们看下源码
  • 我们看先 @EnableScheduling 注解
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Import(SchedulingConfiguration.class)
@Documented
public @interface EnableScheduling {
}
  • 看下 SchedulingConfiguration 类
@Configuration
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public class SchedulingConfiguration {
	@Bean(name = TaskManagementConfigUtils.SCHEDULED_ANNOTATION_PROCESSOR_BEAN_NAME)
	@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
	public ScheduledAnnotationBeanPostProcessor scheduledAnnotationProcessor() {
		return new ScheduledAnnotationBeanPostProcessor();
	}
}
  • 看下 ScheduledAnnotationBeanPostProcessor 类
public ScheduledAnnotationBeanPostProcessor() {
		this.registrar = new ScheduledTaskRegistrar();
	}
  • 看下 ScheduledTaskRegistrar 类，这里使用的是 TaskScheduler 线程池
  • 默认的是 ThreadPoolTaskScheduler

在这里插入图片描述

在这里插入图片描述

配置线程池，让定时任务指定并发执行

  • 配置线程池,实现 SchedulingConfigurer 接口，实现 configureTasks 方法
/**
 * 线程池配置
 *
 * @author liouwb
 * @time 2023-07-27
 */
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskScheduler());
    }
    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        // 设置线程池数量
        taskScheduler.setPoolSize(10);
        // 设置线程池前缀
        taskScheduler.setThreadNamePrefix("parallelScheduler-");
        return taskScheduler;
    }
}
  • 执行结果

在这里插入图片描述

先要线程异步执行

在启动类上添加 @EnableAsync 注解

/**
 * @author liouwb
 */
@SpringBootApplication
@EnableAsync
@EnableScheduling
public class SchedulerApplication{
    public static void main(String[] args) {
        SpringApplication.run(SchedulerApplication.class, args);
    }
}
  • 再方法上添加 @Async 注解便可以让方法异步执行
/**
 * @author liouwb
 */
@Slf4j
@Component
public class TestJob {
    /**
     * 定时任务-串行
     * 固定一秒执行一次
     *
     * @author liouwb
     */
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask1() throws InterruptedException {
        // 让每次任务执行5秒
        Thread.sleep(5 * 1000);
        log.info("测试任务-1");
    }
    @Async
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask2() {
        log.info("测试任务-2");
    }
}
  • 执行结果，可以看到异步线程和并未用到设置的线程池

在这里插入图片描述

springboot异步线程池设置

springboot 异步线程池默认使用的是 ThreadPoolTaskExecutor

ThreadPoolTaskExecutor 和 ThreadPoolTaskScheduler 都在 org.springframework.scheduling.concurrent 下

在这里插入图片描述

``

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(AsyncConfigurationSelector.class)
public @interface EnableAsync {

断点可以看到默认的异步线程池，前缀为 taskScheduler- ,默认核心线程数为 10

默认线程池名称

在这里插入图片描述

  • 下面我们自己配置异步线程池
/**
 * 线程池配置
 *
 * @author liouwb
 */
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskScheduler());
    }
    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(10);
        // 设置线程池前缀
        taskScheduler.setThreadNamePrefix("parallelScheduler-");
        return taskScheduler;
    }
    /**
     * 配置异步线程池
     *
     * @author liouwb
     * @rutern org.springframework.core.task.TaskExecutor
     */
    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数
        executor.setCorePoolSize(Runtime.getRuntime().availableProcessors());
        // 设置最大线程数
        executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors() * 10);
        // 设置队列容量
        executor.setQueueCapacity(Runtime.getRuntime().availableProcessors() * 10);
        // 设置线程活跃时间（秒）
        executor.setKeepAliveSeconds(10);
        // 设置默认线程名称
        executor.setThreadNamePrefix("ansyScheduled-");
        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 等待所有任务结束后再关闭线程池
        executor.setWaitForTasksToCompleteOnShutdown(true);
        return executor;
    }
}
  • 执行结果，可以看到配置的线程池都生效了

在这里插入图片描述

指定线程池执行任务

  • 可以设置多个线程池
/**
 * 线程池配置
 *
 * @author liouwb
 * @time 2023-07-27
 */
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskScheduler());
    }
    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(10);
        // 设置线程池前缀
        taskScheduler.setThreadNamePrefix("parallelScheduler-");
        return taskScheduler;
    }
    /**
     * 配置异步线程池
     *
     * @author liouwb
     * @rutern org.springframework.core.task.TaskExecutor
     */
    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数
        executor.setCorePoolSize(Runtime.getRuntime().availableProcessors());
        // 设置最大线程数
        executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors() * 10);
        // 设置队列容量
        executor.setQueueCapacity(Runtime.getRuntime().availableProcessors() * 10);
        // 设置线程活跃时间（秒）
        executor.setKeepAliveSeconds(10);
        // 设置默认线程名称
        executor.setThreadNamePrefix("ansyScheduled-");
        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 等待所有任务结束后再关闭线程池
        executor.setWaitForTasksToCompleteOnShutdown(true);
        return executor;
    }
    /**
     * 配置异步线程池2
     *
     * @author liouwb
     * @rutern org.springframework.core.task.TaskExecutor
     */
    @Bean
    public TaskExecutor taskExecutor2() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数
        executor.setCorePoolSize(Runtime.getRuntime().availableProcessors());
        // 设置最大线程数
        executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors() * 10);
        // 设置队列容量
        executor.setQueueCapacity(Runtime.getRuntime().availableProcessors() * 10);
        // 设置线程活跃时间（秒）
        executor.setKeepAliveSeconds(10);
        // 设置默认线程名称
        executor.setThreadNamePrefix("异步线程池2-");
        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 等待所有任务结束后再关闭线程池
        executor.setWaitForTasksToCompleteOnShutdown(true);
        return executor;
    }
}
  • 在执行的时候指定线程池的名称
/**
 * @author liouwb
 */
@Slf4j
@Component
public class TestJob {
    /**
     * 定时任务-串行
     * 固定一秒执行一次
     *
     * @author liouwb
     */
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask1() throws InterruptedException {
        // 让每次任务执行5秒
        Thread.sleep(5 * 1000);
        log.info("测试任务-1");
    }
    /**
     * 异步执行
     *
     * @author liouwb
     */
    @Async
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask2() {
        log.info("测试任务-2");
    }
    /**
     * 异步执行
     * 指定使用taskExecutor2线程池
     *
     * @author liouwb
     */
    @Async(value = "taskExecutor2")
    @Scheduled(cron = "0/1 * * * * ?")
    public void testTask3() {
        log.info("测试任务-指定线程池-3");
    }
}
  • 执行结果

在这里插入图片描述

以上就是SpringBoot使用Scheduling实现定时任务的示例代码的详细内容，更多关于SpringBoot Scheduling定时任务的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • java虚拟机之JVM调优详解

    java虚拟机之JVM调优详解

    这篇文章主要介绍了java虚拟机之JVM调优详解,文中有非常详细的代码示例,对正在学习Java虚拟机的小伙伴们有非常好的帮助,需要的朋友可以参考下
    2021-04-04
  • 深入解析Spring中的立即加载和延迟加载

    深入解析Spring中的立即加载和延迟加载

    本文介绍了Spring框架中的立即加载和延迟加载策略，并解释了它们的适用场景和使用方法，根据具体的需求和应用场景，选择合适的加载策略，可以提高应用程序的性能和资源利用效率，感兴趣的朋友跟随小编一起看看吧
    2023-07-07
  • springboot后端配置多个数据源、Mysql数据库的便捷方法

    springboot后端配置多个数据源、Mysql数据库的便捷方法

    实现springboot 后端配置多个数据源、Mysql数据库，只需要新建 Mapper、实体类 相应的文件夹，将不同数据源的文件保存到对应的文件夹下，添加绑定数据库配置Config，就可以轻松完成
    2021-08-08
  • 启动异常invalid constant type:15的解决方案

    启动异常invalid constant type:15的解决方案

    今天小编就为大家分享一篇关于启动异常invalid constant type:15的解决方案，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
    2018-12-12
  • Feign使用@PathVariable方式

    Feign使用@PathVariable方式

    Feign使用@PathVariable注解在URL中插入变量,类似于SpringMVC的用法,通过示例展示了如何使用该注解,并在实际调用中替换占位符
    2024-11-11
  • Spring实战之Bean销毁之前的行为操作示例

    Spring实战之Bean销毁之前的行为操作示例

    这篇文章主要介绍了Spring实战之Bean销毁之前的行为操作,结合实例形式分析了spring在bean销毁之前的行为相关设置与使用技巧,需要的朋友可以参考下
    2019-11-11
  • 解读@RabbitListener起作用的原理

    解读@RabbitListener起作用的原理

    这篇文章主要介绍了解读@RabbitListener起作用的原理，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2023-03-03
  • Java Process与Runtime()的使用及调用cmd命令阻塞的解决方案

    Java Process与Runtime()的使用及调用cmd命令阻塞的解决方案

    这篇文章主要介绍了Java Process与Runtime()的使用及调用cmd命令阻塞的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
    2021-06-06
  • SpringBoot项目设置断点debug调试无效忽略web.xml问题的解决

    SpringBoot项目设置断点debug调试无效忽略web.xml问题的解决

    这篇文章主要介绍了SpringBoot项目设置断点debug调试无效忽略web.xml问题的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-08-08
  • SpringBoot整合Minio的过程(支持公有及私有bucket)

    SpringBoot整合Minio的过程(支持公有及私有bucket)

    Bucket 是存储Object的逻辑空间,每个Bucket之间的数据是相互隔离的,对用户而言,相当于存放文件的顶层文件夹,这篇文章主要介绍了SpringBoot整合Minio的过程(支持公有及私有bucket),需要的朋友可以参考下
    2025-03-03

最新评论