@Configuration 
@EnableAsync 
public class SpringAsyncConfig { ... } 

@SpringBootApplication
@EnableAsync
public class SpringBootApplication {
 public static void main(String[] args) {
 SpringApplication.run(SpringBootApplication.class, args);
 }
}

 @Async //標(biāo)注使用
 public void downloadFile() throws Exception { ... } 

@Async 
public Future<String> asyncMethodWithReturnType() { 
 System.out.println("Execute method asynchronously - " + Thread.currentThread().getName()); 
 try { 
 Thread.sleep(5000); 
 return new AsyncResult<String>("hello world !!!!"); 
 } catch (InterruptedException e) { 
 // 
 } 
 
 return null; 
}

public void testAsyncAnnotationForMethodsWithReturnType() 
 throws InterruptedException, ExecutionException { 
 System.out.println("Invoking an asynchronous method. " + Thread.currentThread().getName()); 
 Future<String> future = asyncAnnotationExample.asyncMethodWithReturnType(); 
 
 while (true) { ///這里使用了循環(huán)判斷，等待獲取結(jié)果信息 
 if (future.isDone()) { //判斷是否執(zhí)行完畢 
 System.out.println("Result from asynchronous process - " + future.get()); 
 break; 
 } 
 System.out.println("Continue doing something else. "); 
 Thread.sleep(1000); 
 } 
}

public class ExceptionHandlingAsyncTaskExecutor implements AsyncTaskExecutor { 
 private AsyncTaskExecutor executor; 
 public ExceptionHandlingAsyncTaskExecutor(AsyncTaskExecutor executor) { 
 this.executor = executor; 
 } 
 ////用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此 
 public void execute(Runnable task) { 
 executor.execute(createWrappedRunnable(task)); 
 } 
 public void execute(Runnable task, long startTimeout) { 
 /用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此 
 executor.execute(createWrappedRunnable(task), startTimeout); 
 } 
 public Future submit(Runnable task) { return executor.submit(createWrappedRunnable(task)); 
 //用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此。 
 } 
 public Future submit(final Callable task) { 
 //用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此。 
 return executor.submit(createCallable(task)); 
 } 
 
 private Callable createCallable(final Callable task) { 
 return new Callable() { 
 public T call() throws Exception { 
  try { 
  return task.call(); 
  } catch (Exception ex) { 
  handle(ex); 
  throw ex; 
  } 
  } 
 }; 
 } 
 
 private Runnable createWrappedRunnable(final Runnable task) { 
 return new Runnable() { 
 public void run() { 
  try { 
  task.run(); 
  } catch (Exception ex) { 
  handle(ex); 
  } 
 } 
 }; 
 } 
 private void handle(Exception ex) { 
 //具體的異常邏輯處理的地方 
 System.err.println("Error during @Async execution: " + ex); 
 } 
}

<task:annotation-driven executor="exceptionHandlingTaskExecutor" scheduler="defaultTaskScheduler" /> 
<bean id="exceptionHandlingTaskExecutor" class="nl.jborsje.blog.examples.ExceptionHandlingAsyncTaskExecutor"> 
 <constructor-arg ref="defaultTaskExecutor" /> 
</bean> 
<task:executor id="defaultTaskExecutor" pool-size="5" /> 
<task:scheduler id="defaultTaskScheduler" pool-size="1" />