不加@EnableScheduling和@Async注解使@Scheduled能够正常执行

时间: 2023-12-12 20:35:07 浏览: 136

@scheduled任务调度使用详解及@scheduled与多线程和@Async异步任务结合使用

在Spring Boot框架中，`@Scheduled`注解是用于实现定时任务的核心工具，它使得开发者可以轻松地在应用中设置周期性的任务执行。本篇文章将深入讲解`@Scheduled`的使用方法，以及如何将其与多线程和`@Async`异步任务相结合，提升应用程序的效率。 ### `@Scheduled`任务调度 `@Scheduled`是Spring Framework中的一个注解，它允许我们在不需要任何第三方库的情况下，如Quartz或CronTrigger，就能创建定时任务。要使用`@Scheduled`，首先需要在配置类上启用定时任务支持，通过`@EnableScheduling`注解： ```java import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; @Configuration @EnableScheduling public class ScheduledConfig { } ``` 然后，我们可以在任何带有`@Component`注解的类中定义一个或多个方法，并用`@Scheduled`注解它们来指定任务的执行周期。例如，我们可以设置一个每隔5秒执行的任务： ```java import org.springframework.scheduled.annotation.Scheduled; import org.springframework.stereotype.Component; @Component public class ScheduledTasks { @Scheduled(fixedRate = 5000) public void reportCurrentTime() { System.out.println("当前时间：" + new Date()); } } ``` 这里的`fixedRate = 5000`表示任务执行间隔为5000毫秒，即5秒。此外，还可以使用`cron`表达式来按照特定的时间格式执行任务： ```java @Scheduled(cron = "0 0/5 * * * ?") public void reportCurrentTimeWithCron() { System.out.println("当前时间（按Cron表达式）：" + new Date()); } ``` 这里的`cron = "0 0/5 * * * ?"`表示每5分钟执行一次。 ### `@Scheduled`与多线程结合默认情况下，`@Scheduled`任务是在同一个线程中顺序执行的，这可能会影响任务的并发性。如果希望多个定时任务并行执行，可以考虑使用多线程。Spring提供了一个`TaskExecutor`接口，我们可以自定义实现并配置到`@Scheduled`中： ```java @Configuration @EnableScheduling public class ScheduledConfig { @Bean(name = "scheduledTaskExecutor") public TaskExecutor taskExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(2); // 核心线程数 executor.setMaxPoolSize(5); // 最大线程数 executor.setQueueCapacity(10); // 队列大小 executor.initialize(); return executor; } @Bean public MyScheduledTask myScheduledTask(@Qualifier("scheduledTaskExecutor") TaskExecutor executor) { return new MyScheduledTask(executor); } } public class MyScheduledTask { private final TaskExecutor executor; public MyScheduledTask(TaskExecutor executor) { this.executor = executor; } @Scheduled(fixedRate = 5000) public void reportCurrentTime() { executor.execute(() -> { // 在这里执行任务 System.out.println("当前时间：" + new Date()); }); } } ``` 这样，`reportCurrentTime`方法内的任务将在我们配置的线程池中异步执行，提高了并发性能。 ### `@Scheduled`与`@Async`异步任务结合 Spring的`@Async`注解用于标记一个方法为异步执行，它与`@Scheduled`结合可以实现异步定时任务。我们需要启用异步支持： ```java @Configuration @EnableAsync public class AsyncConfig implements AsyncConfigurer { @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(2); executor.setMaxPoolSize(5); executor.setQueueCapacity(10); executor.initialize(); return executor; } } ``` 接着，我们可以在`@Scheduled`任务的方法上添加`@Async`，使其异步执行： ```java import org.springframework.scheduled.annotation.Scheduled; import org.springframework.synchronous.annotation.Async; @Async @Scheduled(fixedRate = 5000) public Future<String> asyncReportCurrentTime() { return CompletableFuture.supplyAsync(() -> { // 异步执行的任务 try { Thread.sleep(3000); // 模拟耗时操作 } catch (InterruptedException e) { e.printStackTrace(); } return "当前时间：" + new Date(); }); } ``` 这里的`Future<String>`表示异步任务的结果，可以用于后续处理。总结，`@Scheduled`任务调度是Spring Boot中实现定时任务的关键，它可以配合多线程和`@Async`异步任务提升程序的并发性能。通过自定义线程池和配置`TaskExecutor`，我们可以更好地控制任务的执行方式，从而优化应用程序的运行效率。

根据提供的引用内容，我们可以得出以下结论：要使@Scheduled注解正常执行，需要在Spring Boot应用程序中添加@EnableScheduling注解。这个注解告诉Spring Boot启用计划任务支持。要使@Scheduled注解在多线程环境下正常工作，需要在方法上添加@Async注解，并指定线程池名称。这个注解告诉Spring Boot使用异步方法执行计划任务。如果不添加@EnableScheduling注解，则@Scheduled注解将不会生效，计划任务将不会被执行。如果不添加@Async注解，则@Scheduled注解将在单线程中执行，可能会导致任务阻塞。因此，为了使@Scheduled注解正常工作，需要同时添加@EnableScheduling和@Async注解，并指定线程池名称。

阅读全文

不加@EnableScheduling和@Async注解使@Scheduled能够正常执行

相关推荐

Spring Boot @Async 异步任务执行方法

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

不加@EnableScheduling注解使@Scheduled能够正常执行

@EnableAsync @Async @EnableScheduling @Scheduled

注解schedule的使用

@EnableScheduling定时任务

@Scheduled定时任务不执行

springboot项目scheduled注解

@Scheduled不生效

@Scheduled 配置线程池

springboot @Scheduled详细用法

@Scheduled多线程配置

springboot常用注解

springboot注解详解

springboot 常用的核心注解

基于freeRTOS和STM32F103x的手机远程控制浴室温度系统设计源码

最新推荐

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

Spring Boot中配置定时任务、线程池与多线程池执行的方法

SpringBoot实现定时任务和异步调用

基于freeRTOS和STM32F103x的手机远程控制浴室温度系统设计源码

Windows平台下的Fastboot工具使用指南

管理建模和仿真的文件

DLMS规约深度剖析：从基础到电力通信标准的全面掌握

修改代码，使其正确运行

Python机器学习基础入门与项目实践

"互动学习：行动中的多样性与论文攻读经历"