Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >热乎乎的面经:Spring中Scheduled和Async两种调度方式有啥区别?

热乎乎的面经:Spring中Scheduled和Async两种调度方式有啥区别?

作者头像
冰河
发布于 2021-04-30 06:46:41
发布于 2021-04-30 06:46:41
1.5K00
代码可运行
举报
文章被收录于专栏:冰河技术冰河技术
运行总次数:0
代码可运行

大家好,我是冰河~~

最近有小伙伴出去面试,回来跟我说:冰河,我去XXX公司面试,面试官竟然问了我一个关于Spring中Scheduled和Async调度的问题,我竟然没回答上来,你能不能写一篇关于这个问题的文章呢?我:可以,安排上!于是便有了这篇文章。

好了,我们开始正文吧~~

Spring调度的两种方式

Spring提供了两种后台任务的方法,分别是:

  • 调度任务,@Schedule
  • 异步任务,@Async

当然,使用这两个是有条件的,需要在spring应用的上下文中声明<task:annotation-driven/>当然,如果我们是基于java配置的,需要在配置类上加@EnableScheduling@EnableAsync注解,例如,下面的代码片段。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@EnableScheduling
@EnableAsync
public class WebAppConfig {
   ....

除此之外,还是有第三方库可以调用的,例如Quartz,文章最后我们再简单提下Quartz。

@Schedule调度

先看下@Schedule怎么调用再说。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
public final static long ONE_DAY = 24 * 60 * 60 * 1000;
public final static long ONE_HOUR = 60 * 60 * 1000;
 
@Scheduled(fixedRate = ONE_DAY)
public void scheduledTask() {
   System.out.println(" 我是一个每隔一天就会执行一次的调度任务");
}
 
@Scheduled(fixedDelay = ONE_HOURS)
public void scheduleTask2() {
    System.out.println(" 我是一个执行完后,隔一小时就会执行的任务");
}
 
@Scheduled(initialDelay=1000, fixedRate=5000)
public void doSomething() {
    // something that should execute periodically
}
 
@Scheduled(cron = "0 0/1 * * * ? ")
public void ScheduledTask3() {
    System.out.println(" 我是一个每隔一分钟就就会执行的任务");
}

需要注意的是:

  • 关于@Scheduled注解,里面使用的是Cron表达式,同时我们看到了两个不一样的面孔fixedDelay& fixedRate,前者fixedDelay表示在指定间隔运行程序,例如这个程序在今晚九点运行程序,跑完这个方法后的一个小时,就会再执行一次,而后者fixedRate是指,这个函数每隔一段时间就会被调用(我们这里设置的是一天),不管再次调度的时候,这个方法是在运行还是结束了。而前者就要求是函数运行结束后开始计时的,这就是两者区别。
  • 这个还有一个initialDelay的参数,是第一次调用前需要等待的时间,这里表示被调用后的,推迟一秒再执行,这适合一些特殊的情况。
  • 我们在ServiceImpl类写这些调度任务时候,也需要在ServiceInterface的接口中写多个接口,不然会抛出but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface or 的异常。

@Async调度

有时候我们会调用一些特殊的任务,任务会比较耗时,重要的是,我们不管他返回的后果。这时候我们就需要用这类的异步任务啦,调用后就让它去跑,不堵塞主线程,我们继续干别的。代码像下面这样:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
public void AsyncTask(){
    @Async
    public void doSomeHeavyBackgroundTask(int sleepTime) {
        try {
            Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    @Async
    public Future<String> doSomeHeavyBackgroundTask() {
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return null;
    }
     
    public void printLog() {
         System.out.println(" i print a log ,time=" + System.currentTimeMillis());
    }
 
}

我们写个简单的测试类来测试下

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@RunWith(SpringJUnit4ClassRunner.class)
@WebAppConfiguration
@ContextConfiguration(classes = AsycnTaskConfig.class) //要声明@EnableASync
public class AsyncTaskTest {
    @Autowired
    AsyncTask asyncTask;
    @Test
    public void AsyncTaskTest() throws InterruptedException {
        if (asyncTask != null) {
            asyncTask.doSomeHeavyBackgroundTask(4000);
            asyncTask.printLog();
            Thread.sleep(5000);
        }
    }
}

这感觉比我们手动开线程方便多了,不想异步的话直接把@Async去掉就可以了,另外如果想要返回结果,需要使用Future<>接口。如果想修改Spring Boot的默认线程池配置,可以实现AsyncConfigurer。

需要注意的是:

  • 相对于@scheduled,这个可以有参数和返回个结果,因为这个是我们调用的,而调度的任务是spring调用的。
  • 异步方法不能内部调用,只能像上面那样,外部调用,否则就会变成阻塞主线程的同步任务啦!这里,给大家展示一个活生生的大坑!例如下面的代码案例。
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
public void AsyncTask(){
    public void fakeAsyncTaskTest(){
        doSomeHeavyBackgroundTask(4000);
        printLog();
        //你会发现,当你像这样内部调用的时候,居然是同步执行的,不是异步的!!
    }
     
    @Async
    public void doSomeHeavyBackgroundTask(int sleepTime) {
        try {
            Thread.sleep(sleepTime);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
     
    public void printLog() {
        System.out.println(" i print a log ");
    }
}

另外一点就是不要重复的扫描,这也会导致异步无效,具体的可以看这个stackoveflow的spring-async-not-working Issue。

关于异常处理,难免在这个异步执行过程中有异常发生,对于这个问题,Spring提供的解决方案如下,实现 AsyncUncaughtExceptionHandler接口。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {
    @Override
    public void handleUncaughtException(Throwable ex, Method method, Object... params) {
        // handle exception
    }
}

写好我们的异常处理后,我们需要配置一下,告诉Spring,这个异常处理就是我们在运行异步任务时候,抛出错误时的异常终结者。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    @Bean
    public AsyncTask asyncBean() {
        return new AsyncTask();
    }
     
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(7);
        executor.setMaxPoolSize(42);
        executor.setQueueCapacity(11);
        executor.setThreadNamePrefix("MyExecutor-");
        executor.initialize();
        return executor;
    }
     
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
         return new MyAsyncUncaughtExceptionHandler();
    }
}

简单聊下Quartz登场

Spring中除了@Scheduled和@Async注解外,还有一个和Spring整合的第三方库叫Quartz,看了下官网的使用简介,也是挺逗的,现在都习惯用Maven,Gradle之类来关系这些依赖了,他还叫人下载,也是不知为何,详情点击->http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start

估计有可能是因为没再维护了的原因吧,看了下,最新版2.2居然是Sep, 2013更新的…

Quartz居然是停更了,不过Quartz作为一个企业级应用的任务调度框架,还是一个可以的候选项目,作为其他方案的兜底方案。

这里不铺开讲,有兴趣的小伙伴们就去官网看下吧。整体用起来感觉是没有Spring自己的后台任务方便,不过也可以接受,只需要简单的配置就可以使用了。

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2021-04-28,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 冰河技术 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
定时任务@Scheduled 和 异步@Async
@EnableScheduling 开启定时任务功能,方法所在类需要加@Component @Scheduled(Cron= “”) 指定执行的时间
鱼找水需要时间
2023/02/16
6090
java之Spring 框架实战: TaskExecutor
使用 ThreadPoolTaskExecutor 可以实现一个 TaskExecutor.
IT工作者
2022/07/04
5090
@Async 注解的使用
在 Spring 中,@Async 标注的方法,在执行的时候,是异步运行的,它运行在独立的线程中,程序不会被该方法所阻塞。
水货程序员
2018/11/13
5.6K0
Spring Boot(5) @Async异步线程池详解
在Spring4中,Spring中引入了一个新的注解@Async,这个注解让我们在使用Spring完成异步操作变得非常方便。
黄规速
2022/04/14
5.5K0
Spring Boot(5) @Async异步线程池详解
SpringBoot中Async异步方法和定时任务介绍
1.功能说明 Spring提供了Async注解来实现方法的异步调用。 即当调用Async标识的方法时,调用线程不会等待被调用方法执行完成即返回继续执行以下操作,而被调用的方法则会启动一个独立线程来执行此方法。 这种异步执行的方式通常用于处理接口中不需要返回给用户的数据处理。比如当注册的时候,只需要将用户信息返回用户,而关于信息的保存操作可以使用异步执行。 Spring提供了Scheduled注解来实现定时任务的功能。 在异步方法和定时任务功能中都是开发这自己定义需要执行的方法,然后交给Spring容器管理
代码改变世界-coding
2018/07/03
2.1K0
聊一聊非分布式任务调度@Scheduled
注意:cron表达式可分为6或7个占位符,但在spring自带的定时任务中,cron只支持6个参数,若使用7个参数就会报错
小熊学Java
2023/07/16
4440
聊一聊非分布式任务调度@Scheduled
补习系列(9)-springboot 定时器,你用对了吗
大多数的应用程序都离不开定时器,通常在程序启动时、运行期间会需要执行一些特殊的处理任务。
美码师
2019/01/23
8150
CMS-Spring Task定时任务
根据分布式事务的研究结果,订单服务需要定时扫描任务表向MQ发送任务。本节研究定时任务处理的方案,并实 现定时任务扫描任务表并向MQ发送消息。
cwl_java
2020/01/14
4250
通过源码理解Spring中@Scheduled的实现原理并且实现调度任务动态装载
最近的新项目和数据同步相关,有定时调度的需求。之前一直有使用过Quartz、XXL-Job、Easy Scheduler等调度框架,后来越发觉得这些框架太重量级了,于是想到了Spring内置的Scheduling模块。而原生的Scheduling模块只是内存态的调度模块,不支持任务的持久化或者配置(配置任务通过@Scheduled注解进行硬编码,不能抽离到类之外),因此考虑理解Scheduling模块的底层原理,并且基于此造一个简单的轮子,使之支持调度任务配置:通过配置文件或者JDBC数据源。
Throwable
2020/06/23
2.7K0
通过源码理解Spring中@Scheduled的实现原理并且实现调度任务动态装载
Spring @Scheduled 怎么使用才正确
Spring scheduled 默认为单线程,最近就发现生产上有某个服务实例不按时执行 task 任务,最后排查出使用了@Scheduled,发现一个任务执行12个小时,导致其他任务都在排队等待,没有在规定时间去抢占分布式锁。
BUG弄潮儿
2023/02/24
3.3K0
Spring @Scheduled 怎么使用才正确
重学SpringBoot系列之异步任务与定时任务
在 Spring Boot 入口类上配置 @EnableAsync 注解开启异步处理。 创建任务抽象类 AbstractTask,并分别配置三个任务方法 doTaskOne(),doTaskTwo(),doTaskThree()。
大忽悠爱学习
2021/12/07
1.5K0
重学SpringBoot系列之异步任务与定时任务
Spring6.x对调度和异步执行的注解支持
要启用 @Scheduled 和 @Async ,在 @Configuration 类(或者在启动类)添加 @EnableScheduling 和 @EnableAsync,如下:
JavaEdge
2023/11/24
2610
Spring 定时任务
本文参考自Spring官方文档 34. Task Execution and Scheduling。
乐百川
2022/05/05
1K0
Spring框架提供的异步执行能力
Spring Framework分别使用TaskExecutor和TaskScheduler接口提供异步执行和任务调度的抽象。Spring还具有支持线程池或在应用程序服务器环境中委托给CommonJ的接口的实现。最终,在公共接口背后使用这些实现抽象出了Java SE 5,Java SE 6和Java EE环境之间的差异。本节我们着重讲解@Async如何实现异步处理。
田维常
2019/07/20
1K0
Spring Boot 实现定时任务的 4 种方式
在SpringBoot项目中,我们可以很优雅的使用注解来实现定时任务,首先创建项目,导入依赖:
二哥聊运营工具
2021/12/17
6690
关于Spring中的@Async注解以及为什么不建议使用 - Java技术债务
Async 注解是 Java 8 中的一个注解,用于标识一个方法是异步执行的。当一个方法被标记为 Async 时,该方法将在一个新的线程中执行,并且可以立即返回一个 CompletableFuture 对象。使用 CompletableFuture 可以更轻松地管理异步计算的结果。下面是一个使用 Async 注解的示例代码:
Java技术债务
2024/06/21
3710
Java中定时任务的6种实现方式,你知道几种?
几乎在所有的项目中,定时任务的使用都是不可或缺的,如果使用不当甚至会造成资损。还记得多年前在做金融系统时,出款业务是通过定时任务对外打款,当时由于银行接口处理能力有限,外加定时任务使用不当,导致发出大量重复出款请求。还好在后面环节将交易卡在了系统内部,未发生资损。
程序新视界
2021/12/07
3K0
Java中定时任务的6种实现方式,你知道几种?
SpringBoot2.0 基础案例(04):定时任务和异步任务的使用方式
同步调用 程序按照代码顺序依次执行,每一行程序都必须等待上一行程序执行完成之后才能执行; 异步调用 顺序执行时,不等待异步调用的代码块返回结果就执行后面的程序。
知了一笑
2019/07/19
7720
Spring开启方法异步执行
@EnableAsync @Target(ElementType.TYPE) @Retention(RetentionPolicy.RUNTIME) @Documented @Import(Async
Java技术栈
2018/03/30
1.4K0
Spring开启方法异步执行
SpringBoot学习笔记(十七:异步调用)
在实际开发中,有时候为了及时处理请求和进行响应,我们可能使用异步调用,同步调用指程序按照定义顺序依次执行,每一行程序都必须等待上一行程序执行完成之后才能执行;异步调用指程序在顺序执行时,不等待异步调用的语句返回结果就执行后面的程序。异步调用的实现有很多,例如多线程、定时任务、消息队列等。
三分恶
2020/07/16
6180
相关推荐
定时任务@Scheduled 和 异步@Async
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验