Spring中Scheduled和Async两种调度方式有什么区别

这篇文章主要介绍“Spring中Scheduled和Async两种调度方式有什么区别”，在日常操作中，相信很多人在Spring中Scheduled和Async两种调度方式有什么区别问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Spring中Scheduled和Async两种调度方式有什么区别”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

Spring调度的两种方式

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

• 调度任务，@Schedule

• 异步任务，@Async

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

@EnableScheduling @EnableAsync public 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表示在指定间隔运行程序，例如这个程序在今晚九点运行程序，跑完这个方法后的一个小时，就会再执行一次，而后者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调度

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

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());     }   }

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

@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调用的。

• 异步方法不能内部调用，只能像上面那样，外部调用，否则就会变成阻塞主线程的同步任务啦!这里，给大家展示一个活生生的大坑!例如下面的代码案例。

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 @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更新的&hellip;

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

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

到此，关于“Spring中Scheduled和Async两种调度方式有什么区别”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！