Spring中Scheduled和Async兩種調(diào)度方式有什么區(qū)別

這篇文章主要介紹“Spring中Scheduled和Async兩種調(diào)度方式有什么區(qū)別”，在日常操作中，相信很多人在Spring中Scheduled和Async兩種調(diào)度方式有什么區(qū)別問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”Spring中Scheduled和Async兩種調(diào)度方式有什么區(qū)別”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

Spring調(diào)度的兩種方式

Spring提供了兩種后臺任務的方法,分別是:

• 調(diào)度任務，@Schedule

• 異步任務，@Async

當然，使用這兩個是有條件的，需要在spring應用的上下文中聲明當然，如果我們是基于java配置的，需要在配置類上加@EnableScheduling和@EnableAsync注解，例如，下面的代碼片段。

@EnableScheduling @EnableAsync public class WebAppConfig {    .... ｝

除此之外，還是有第三方庫可以調(diào)用的，例如Quartz，文章最后我們再簡單提下Quartz。

@Schedule調(diào)度

先看下@Schedule怎么調(diào)用再說。

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(" 我是一個每隔一天就會執(zhí)行一次的調(diào)度任務"); }   @Scheduled(fixedDelay = ONE_HOURS) public void scheduleTask2() {     System.out.println(" 我是一個執(zhí)行完后，隔一小時就會執(zhí)行的任務"); }   @Scheduled(initialDelay=1000, fixedRate=5000) public void doSomething() {     // something that should execute periodically }   @Scheduled(cron = "0 0/1 * * * ? ") public void ScheduledTask3() {     System.out.println(" 我是一個每隔一分鐘就就會執(zhí)行的任務"); }

需要注意的是：

• 關于@Scheduled注解，里面使用的是Cron表達式，同時我們看到了兩個不一樣的面孔fixedDelay&  fixedRate，前者fixedDelay表示在指定間隔運行程序，例如這個程序在今晚九點運行程序，跑完這個方法后的一個小時，就會再執(zhí)行一次，而后者fixedDelay是指，這個函數(shù)每隔一段時間就會被調(diào)用(我們這里設置的是一天)，不管再次調(diào)度的時候，這個方法是在運行還是結(jié)束了。而前者就要求是函數(shù)運行結(jié)束后開始計時的，這就是兩者區(qū)別。

• 這個還有一個initialDelay的參數(shù)，是第一次調(diào)用前需要等待的時間，這里表示被調(diào)用后的，推遲一秒再執(zhí)行，這適合一些特殊的情況。

• 我們在serviceImpl類寫這些調(diào)度任務時候，也需要在ServiceInterface的接口口中寫多個接口，不然會拋出but not found in  any interface(s) for bean JDK proxy.Either pull the method up to an interface or  的異常。

@Async調(diào)度

有時候我們會調(diào)用一些特殊的任務，任務會比較耗時，重要的是，我們不管他返回的后果。這時候我們就需要用這類的異步任務啦，調(diào)用后就讓它去跑，不堵塞主線程，我們繼續(xù)干別的。代碼像下面這樣:

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去掉就可以了，另外如果想要返回結(jié)果，需要使用Future<>接口。如果想修改Spring  Boot的默認線程池配置，可以實現(xiàn)AsyncConfigurer。

需要注意的是：

• 相對于@scheduled，這個可以有參數(shù)和返回個結(jié)果，因為這個是我們調(diào)用的，而調(diào)度的任務是spring調(diào)用的。

• 異步方法不能內(nèi)部調(diào)用，只能像上面那樣，外部調(diào)用，否則就會變成阻塞主線程的同步任務啦!這里，給大家展示一個活生生的大坑!例如下面的代碼案例。

public void AsyncTask(){     public void fakeAsyncTaskTest(){         doSomeHeavyBackgroundTask(4000);         printLog();         //你會發(fā)現(xiàn)，當你像這樣內(nèi)部調(diào)用的時候，居然是同步執(zhí)行的，不是異步的??！     }           @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。

關于異常處理，難免在這個異步執(zhí)行過程中有異常發(fā)生，對于這個問題，Spring提供的解決方案如下,實現(xiàn)  AsyncUncaughtExceptionHandler接口。

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

寫好我們的異常處理后，我們需要配置一下，告訴Spring，這個異常處理就是我們在運行異步任務時候，拋出錯誤時的異常終結(jié)者。

@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，看了下官網(wǎng)的使用簡介，也是挺逗的，現(xiàn)在都習慣用Maven，Gradle之類來關系這些依賴了，他還叫人下載，也是不知為何，詳情點擊->http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start

估計有可能是因為沒再維護了的原因吧，看了下，最新版2.2居然是Sep, 2013更新的&hellip;

Quartz居然是停更了，不過Quartz作為一個企業(yè)級應用的任務調(diào)度框架，還是一個可以的候選項目，作為其他方案的兜底方案。

這里不鋪開講，有興趣的小伙伴們就去官網(wǎng)看下吧。整體用起來感覺是沒有Spring自己的后臺任務方便，不過也可以接受，只需要簡單的配置就可以使用了。

到此，關于“Spring中Scheduled和Async兩種調(diào)度方式有什么區(qū)別”的學習就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注億速云網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>