Spring的兩種任務調度Scheduled和Async

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

調度任務，@Schedule
異步任務，@Async

當然，使用這兩個是有條件的，需要在spring應用的上下文中聲明
<task:annotation-driven/>當然，如果我們是基于java配置的，需要在配置哪里加多EnableScheduling和@EnableAsync?就像下面這樣

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

除此之外，還是有第三方庫可以調用的，例如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(" 我是一個每隔一分鐘就就會執行的任務");
}

需要注意的

關于最后一個，在指定時間執行的任務，里面使用的是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<>,關于這個Future，完全可以寫多幾篇文章介紹，順便把FutureTask介紹了。如果想修改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整合的第三方庫叫Quartz
看了下官網的使用簡介，也是挺逗的，現在都習慣用maven，gradle之類來關系這些依賴了，他還叫人下載，也是不知為何，詳情點擊－>
http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start
估計有可能是因為沒再維護了的原因吧，看了下，最新版2.2居然是Sep, 2013更新的…
居然是停更的，不過Quartz作為一個企業級應用的任務調度框架，還是一個可以的候選項目的。
這里不鋪開講，有興趣就去官網看下吧。整體用起來感覺是沒有spring自己的后臺任務方便，不過也可以接受，只需要簡單的配置就可以使用了。

http://www.cnblogs.com/slimer/p/6401394.html

轉載于:https://www.cnblogs.com/softidea/p/6855034.html

本文來自互聯網用戶投稿，該文觀點僅代表作者本人，不代表本站立場。本站僅提供信息存儲空間服務，不擁有所有權，不承擔相關法律責任。
如若轉載，請注明出處：http://www.pswp.cn/news/541373.shtml
繁體地址，請注明出處：http://hk.pswp.cn/news/541373.shtml
英文地址，請注明出處：http://en.pswp.cn/news/541373.shtml

如若內容造成侵權/違法違規/事實不符，請聯系多彩編程網進行投訴反饋email:809451989@qq.com，一經查實，立即刪除！