Spring中@Async注解实现异步调详解

/**
 * @author 佛大Java程序员
 * @since 1.0.0
 */
@Configuration
@ComponentScan("com.whl.asyncdemo")
@EnableAsync
public class TaskExecutorConfig implements AsyncConfigurer {

  @Override
  public Executor getAsyncExecutor() {
  ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(5);
    taskExecutor.setMaxPoolSize(10);
    taskExecutor.setQueueCapacity(25);
    taskExecutor.initialize();
    return taskExecutor;
  }

  @Override
  public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    return null;
  }
}

/**
 * @author 佛大Java程序员
 * @since 1.0.0
 */
@Service
public class AsyncTaskService {

  @Async
  public void executeAsyncTask(Integer i){
    System.out.println("执行异步任务1：" + i);
  }

  @Async
  public void executeAsyncTaskPlus(Integer i){
    System.out.println("执行异步任务2 " +(i+1));
  }}

/**
 * @author 佛大Java程序员
 * @since 1.0.0
 */
public class Main {

  public static void main(String[] args) {

    AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TaskExecutorConfig.class);
    AsyncTaskService asyncTaskService = context.getBean(AsyncTaskService.class);

    for (int i = 0; i < 5 ; i++) {
      asyncTaskService.executeAsyncTask(i);
      asyncTaskService.executeAsyncTaskPlus(i);
    }

    //校验异步方法是否先返回结果值
    System.out.println("返回执行成功，验证异步是否先返回结果值");
    context.close();

  }
}