@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ @ WARNING: REMOTE HOST IDENTIFICATION HAS CHANGED! @ @@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@ IT IS POSSIBLE THAT SOMEONE IS DOING SOMETHING NASTY! Someone could be eavesdropping on you right now (man-in-the-middle attack)! It is also possible that a host key has just been changed. The fingerprint for the ECDSA key sent by the remote host is SHA256:gUrLuHuDBoIs3qE15pUzYZrJ87UotjmGjTJQPmrvWq8. Please contact your system administrator. Add correct host key in /home/L1046664571/.ssh/known_hosts to get rid of this message. Offending ECDSA key in /home/L1046664571/.ssh/known_hosts:1 ECDSA host key for 10.180.210.237 has changed and you have requested strict checking. Host key verification failed.翻译

时间: 2023-08-28 15:14:04 浏览: 269

@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`，我们可以更好地控制任务的执行方式，从而优化应用程序的运行效率。

这段信息是一个警告，表示远程主机的身份验证已经改变，可能有人正在进行恶意活动，可能存在中间人攻击。也有可能是主机密钥刚刚被更改。远程主机发送的ECDSA密钥的指纹是SHA256：gUrLuHuDBoIs3qE15pUzYZrJ87UotjmGjTJQPmrvWq8。请联系系统管理员，在/home/L1046664571/.ssh/known_hosts中添加正确的主机密钥，以消除此消息。 offending ECDSA密钥在 / home / L1046664571 / .ssh / known_hosts: 1，ECDSA主机密钥10.180.210.237已更改，您已请求进行严格检查，因此主机密钥验证失败。

阅读全文

相关推荐

【Spring AOP】@Aspect结合案例详解（一）: @Pointcut使用@annotation + 五种通知

通过Sm@rtServer远程访问西门子触摸屏的具体方法示例.docx

10档行情LOGO@@@@@@@@@@@@@@@@@@

高质量@@@@@@C++

我的资源!~~~@@@@@@@@@@

很好的触发器代码@@@@@@@

@@@@LOGO.fll

鼠标取色工具@@@@@

Halcon17.12@@@@@@破解.zip

解释@Component @Controller @Service @Repository

飞歌开机logo@@@@LOGO.fll

《认识图形》教学设计@@@@@.doc

@RT@TYFVUY

极速QQ@@

Spring注解 @Component、@Repository、@Service、@Controller区别

@Response和@Request

mssql @@ERROR 使用

images:感谢@GitHub和@PicGo @uPic

Spring注解@Component、@Repository、@Service、@Controller区别.doc

最新推荐

@Controller、@RestController注解区别详解

Spring @Bean注解配置及使用方法解析

详解vue中在循环中使用@mouseenter 和 @mouseleave事件闪烁问题解决方法

小议Java中@param注解与@see注解的作用

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

黑板风格计算机毕业答辩PPT模板下载

管理建模和仿真的文件

提升点阵式液晶显示屏效率技术

在SoC芯片的射频测试中，ATE设备通常如何执行系统级测试以保证芯片量产的质量和性能一致？

CodeSandbox实现ListView快速创建指南