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

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

好了，我们开始正文吧~~
Spring调度的两种方式

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

调度任务，@Schedule
异步任务，@Async

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

@EnableScheduling@EnableAsyncpublic class WebAppConfig { …｝

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

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

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是指，这个函数每隔一段时间就会被调用（我们这里设置的是一天），不管再次调度的时候，这个方法是在运行还是结束了。而前者就要求是函数运行结束后开始计时的，这就是两者区别。在此我向大家推荐一个架构学习交流圈。交流学习指导伪鑫：1253431195（里面有大量的面试题及答案）里面会分享一些资深架构师录制的视频录像：有Spring，MyBatis，Netty源码分析，高并发、高性能、分布式、微服务架构的原理，JVM性能优化、分布式架构等这些成为架构师必备的知识体系。还能领取免费的学习资源，目前受益良多
这个还有一个initialDelay的参数，是第一次调用前需要等待的时间，这里表示被调用后的，推迟一秒再执行，这适合一些特殊的情况。
我们在ServiceImpl类写这些调度任务时候，也需要在ServiceInterface的接口中写多个接口，不然会抛出but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface or 的异常。

@Async调度

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

public void AsyncTask(){ @Async public void doSomeHeavyBackgroundTask(int sleepTime) { try { Thread.sleep(sleepTime); } catch (InterruptedException e) { e.printStackTrace(); } } @Async public Future 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()); } }

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

@RunWith(SpringJUnit4ClassRunner.class)@WebAppConfiguration@ContextConfiguration(classes = AsycnTaskConfig.class) //要声明@EnableASyncpublic 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调用的。
异步方法不能内部调用，只能像上面那样，外部调用，否则就会变成阻塞主线程的同步任务啦！这里，给大家展示一个活生生的大坑！例如下面的代码案例。

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接口。

public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler { @Override public void handleUncaughtException(Throwable ex, Method method, Object… params) { // handle exception }}

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

@Configuration@EnableAsyncpublic 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自己的后台任务方便，不过也可以接受，只需要简单的配置就可以使用了。

热乎乎的面经：Spring中Scheduled和Async两种调度方式有啥区别？相关推荐

Spring中自动注入的两种方式
目录 1. 前言 2. set注入和构造注入. 3. 什么情况下要使用自动注入? 4. 自动注入之byName 5. 自动注入之byType注入 1. 前言 Spring的核心技术IOC(Intoro ...
【Spring】Spring中AOP解析上两种动态代理方式与ProxyFactory代理工厂
1.两种动态代理方式演示 1.1 JDK动态代理 JDK的动态代理,就是在程序运行的过程中,根据被代理的接口来动态生成代理类的class文件,并加载运行的过程.要求被代理类必须实现一个接口 . 如下案 ...
Java中实现多线程的两种方式之间的区别
Java提供了线程类Thread来创建多线程的程序.其实,创建线程与创建普通的类的对象的操作是一样的,而线程就是Thread类或其子类的实例对象.每个Thread对象描述了一个单独的线程.要产生一个线 ...
java多线程区别_Java中实现多线程的两种方式之间的区别
Java提供了线程类Thread来创建多线程的程序.其实,创建线程与创建普通的类的对象的操作是一样的,而线程就是Thread类或其子类的实例对象.每个Thread对象描述了一个单独的线程.要产生一个线 ...
ajax onload怎么用,Ajax中onload和onreadystatechange两种请求方式的区别
一. onreadystatechange 1. XMLHttpRequest对象有一个属性readyState,将其(xhr.readyState)打印后发现.进入onreadystatechang ...
java中创建两种线程的方式_java中创建线程的两种方式有什么区别？
*** 一.创建线程 1.继承Thread类定义类继承Thread, 重写run()方法, 将线程中要执行的代码写在run()方法中创建该类对象, 调用start()方法就可以开启一条新线程, 新 ...
Spring中@Resource与@Autowired、@Qualifier的用法与区别
Spring中@Resource与@Autowired.@Qualifier的用法与区别 1.@Autowired与@Resource都可以用来装配bean. 都可以写在字段上,或写在setter方法 ...
Spring 中获取 request 的几种方法，及其线程安全性分析
概述在使用Spring MVC开发Web系统时,经常需要在处理请求时使用request对象,比如获取客户端ip地址.请求的url.header中的属性(如cookie.授权信息).body中的数据等 ...
java中四种注入注解,Spring中依赖注入的四种方式
在Spring容器中为一个bean配置依赖注入有三种方式: · 使用属性的setter方法注入这是最常用的方式: · 使用构造器注入: · 使用Filed注入(用于注解方式). 使用属性的sett ...

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

热乎乎的面经：Spring中Scheduled和Async两种调度方式有啥区别？相关推荐

最新文章

热门文章