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

大家好，我是冰河~~

成都创新互联公司坚信：善待客户，将会成为终身客户。我们能坚持多年，是因为我们一直可值得信赖。我们从不忽悠初访客户，我们用心做好本职工作，不忘初心，方得始终。10余年网站建设经验成都创新互联公司是成都老牌网站营销服务商,为您提供网站制作、网站设计、网站设计、H5页面制作、网站制作、高端网站设计、微信平台小程序开发服务,给众多知名企业提供过好品质的建站服务。

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

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

Spring调度的两种方式

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

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

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

 
 
 
 
    
  
  
  
  
  1. @EnableScheduling
    2. 
  
  
  
  
  2. @EnableAsync
    3. 
  
  
  
  
  3. public class WebAppConfig {
    4. 
  
  
  
  
  4.    ....
    5. 
  
  
  
  
  5. ｝
    6.

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

@Schedule调度

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

 
 
 
 
    
  
  
  
  
  1. public final static long ONE_DAY = 24 * 60 * 60 * 1000;
    2. 
  
  
  
  
  2. public final static long ONE_HOUR = 60 * 60 * 1000;
    3. 
  
  
  
  
  3.  
    4. 
  
  
  
  
  4. @Scheduled(fixedRate = ONE_DAY)
    5. 
  
  
  
  
  5. public void scheduledTask() {
    6. 
  
  
  
  
  6.    System.out.println(" 我是一个每隔一天就会执行一次的调度任务");
    7. 
  
  
  
  
  7. }
    8. 
  
  
  
  
  8.  
    9. 
  
  
  
  
  9. @Scheduled(fixedDelay = ONE_HOURS)
    10. 
  
  
  
  
  10. public void scheduleTask2() {
    11. 
  
  
  
  
  11.     System.out.println(" 我是一个执行完后，隔一小时就会执行的任务");
    12. 
  
  
  
  
  12. }
    13. 
  
  
  
  
  13.  
    14. 
  
  
  
  
  14. @Scheduled(initialDelay=1000, fixedRate=5000)
    15. 
  
  
  
  
  15. public void doSomething() {
    16. 
  
  
  
  
  16.     // something that should execute periodically
    17. 
  
  
  
  
  17. }
    18. 
  
  
  
  
  18.  
    19. 
  
  
  
  
  19. @Scheduled(cron = "0 0/1 * * * ? ")
    20. 
  
  
  
  
  20. public void ScheduledTask3() {
    21. 
  
  
  
  
  21.     System.out.println(" 我是一个每隔一分钟就就会执行的任务");
    22. 
  
  
  
  
  22. }
    23.

需要注意的是：

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

@Async调度

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

 
 
 
 
    
  
  
  
  
  1. public void AsyncTask(){
    2. 
  
  
  
  
  2.     @Async
    3. 
  
  
  
  
  3.     public void doSomeHeavyBackgroundTask(int sleepTime) {
    4. 
  
  
  
  
  4.         try {
    5. 
  
  
  
  
  5.             Thread.sleep(sleepTime);
    6. 
  
  
  
  
  6.         } catch (InterruptedException e) {
    7. 
  
  
  
  
  7.             e.printStackTrace();
    8. 
  
  
  
  
  8.         }
    9. 
  
  
  
  
  9.     }
    10. 
  
  
  
  
  10.     @Async
    11. 
  
  
  
  
  11.     public Future doSomeHeavyBackgroundTask() {
    12. 
  
  
  
  
  12.         try {
    13. 
  
  
  
  
  13.             Thread.sleep(3000);
    14. 
  
  
  
  
  14.         } catch (InterruptedException e) {
    15. 
  
  
  
  
  15.             e.printStackTrace();
    16. 
  
  
  
  
  16.         }
    17. 
  
  
  
  
  17.         return null;
    18. 
  
  
  
  
  18.     }
    19. 
  
  
  
  
  19.      
    20. 
  
  
  
  
  20.     public void printLog() {
    21. 
  
  
  
  
  21.          System.out.println(" i print a log ,time=" + System.currentTimeMillis());
    22. 
  
  
  
  
  22.     }
    23. 
  
  
  
  
  23.  
    24. 
  
  
  
  
  24. }
    25.

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

 
 
 
 
    
  
  
  
  
  1. @RunWith(SpringJUnit4ClassRunner.class)
    2. 
  
  
  
  
  2. @WebAppConfiguration
    3. 
  
  
  
  
  3. @ContextConfiguration(classes = AsycnTaskConfig.class) //要声明@EnableASync
    4. 
  
  
  
  
  4. public class AsyncTaskTest {
    5. 
  
  
  
  
  5.     @Autowired
    6. 
  
  
  
  
  6.     AsyncTask asyncTask;
    7. 
  
  
  
  
  7.     @Test
    8. 
  
  
  
  
  8.     public void AsyncTaskTest() throws InterruptedException {
    9. 
  
  
  
  
  9.         if (asyncTask != null) {
    10. 
  
  
  
  
  10.             asyncTask.doSomeHeavyBackgroundTask(4000);
    11. 
  
  
  
  
  11.             asyncTask.printLog();
    12. 
  
  
  
  
  12.             Thread.sleep(5000);
    13. 
  
  
  
  
  13.         }
    14. 
  
  
  
  
  14.     }
    15. 
  
  
  
  
  15. }
    16.

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

需要注意的是：

  • 相对于@scheduled，这个可以有参数和返回个结果，因为这个是我们调用的，而调度的任务是spring调用的。
  • 异步方法不能内部调用，只能像上面那样，外部调用，否则就会变成阻塞主线程的同步任务啦!这里，给大家展示一个活生生的大坑!例如下面的代码案例。
 
 
 
 
    
  
  
  
  
  1. public void AsyncTask(){
    2. 
  
  
  
  
  2.     public void fakeAsyncTaskTest(){
    3. 
  
  
  
  
  3.         doSomeHeavyBackgroundTask(4000);
    4. 
  
  
  
  
  4.         printLog();
    5. 
  
  
  
  
  5.         //你会发现，当你像这样内部调用的时候，居然是同步执行的，不是异步的！！
    6. 
  
  
  
  
  6.     }
    7. 
  
  
  
  
  7.      
    8. 
  
  
  
  
  8.     @Async
    9. 
  
  
  
  
  9.     public void doSomeHeavyBackgroundTask(int sleepTime) {
    10. 
  
  
  
  
  10.         try {
    11. 
  
  
  
  
  11.             Thread.sleep(sleepTime);
    12. 
  
  
  
  
  12.         } catch (InterruptedException e) {
    13. 
  
  
  
  
  13.             e.printStackTrace();
    14. 
  
  
  
  
  14.         }
    15. 
  
  
  
  
  15.     }
    16. 
  
  
  
  
  16.      
    17. 
  
  
  
  
  17.     public void printLog() {
    18. 
  
  
  
  
  18.         System.out.println(" i print a log ");
    19. 
  
  
  
  
  19.     }
    20. 
  
  
  
  
  20. }
    21.

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

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

 
 
 
 
    
  
  
  
  
  1. public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler {
    2. 
  
  
  
  
  2.     @Override
    3. 
  
  
  
  
  3.     public void handleUncaughtException(Throwable ex, Method method, Object... params) {
    4. 
  
  
  
  
  4.         // handle exception
    5. 
  
  
  
  
  5.     }
    6. 
  
  
  
  
  6. }
    7.

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

 
 
 
 
    
  
  
  
  
  1. @Configuration
    2. 
  
  
  
  
  2. @EnableAsync
    3. 
  
  
  
  
  3. public class AsyncConfig implements AsyncConfigurer {
    4. 
  
  
  
  
  4.     @Bean
    5. 
  
  
  
  
  5.     public AsyncTask asyncBean() {
    6. 
  
  
  
  
  6.         return new AsyncTask();
    7. 
  
  
  
  
  7.     }
    8. 
  
  
  
  
  8.      
    9. 
  
  
  
  
  9.     @Override
    10. 
  
  
  
  
  10.     public Executor getAsyncExecutor() {
    11. 
  
  
  
  
  11.         ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    12. 
  
  
  
  
  12.         executor.setCorePoolSize(7);
    13. 
  
  
  
  
  13.         executor.setMaxPoolSize(42);
    14. 
  
  
  
  
  14.         executor.setQueueCapacity(11);
    15. 
  
  
  
  
  15.         executor.setThreadNamePrefix("MyExecutor-");
    16. 
  
  
  
  
  16.         executor.initialize();
    17. 
  
  
  
  
  17.         return executor;
    18. 
  
  
  
  
  18.     }
    19. 
  
  
  
  
  19.      
    20. 
  
  
  
  
  20.     @Override
    21. 
  
  
  
  
  21.     public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    22. 
  
  
  
  
  22.          return new MyAsyncUncaughtExceptionHandler();
    23. 
  
  
  
  
  23.     }
    24. 
  
  
  
  
  24. }
    25.

简单聊下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两种调度方式有啥区别？
网站链接：http://www.gawzjz.com/qtweb/news49/161399.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

python知识

行业网站建设

郫县网站建设　　 　重庆电信五里店机房　　 　域名ssl证书　　 　云南护栏打桩机　　 　广汉网站建设　　 　app开发　　 　眉山网站建设　　 　犀浦防护栏定制　　 　软文发布平台　　 　四川雕琢时光　　 　德阳定制网站建设　　 　成都众诚伟业　　 　香港空间腾讯云　　 　青羊总部基地　　 　成都网站设计　　 　西部信息中心　　 　手机网站建设　　 　成都网站建设公司　　 　瑞杰管理　　 　尊格展览