Spring Boot利用@Async如何实现异步调用：自定义线程池

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

 @EnableAsync
 @Configuration
 class TaskPoolConfig {

  @Bean("taskExecutor")
  public Executor taskExecutor() {
   ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
   executor.setCorePoolSize(10);
   executor.setMaxPoolSize(20);
   executor.setQueueCapacity(200);
   executor.setKeepAliveSeconds(60);
   executor.setThreadNamePrefix("taskExecutor-");
   executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
   return executor;
  }
 }
}

@Slf4j
@Component
public class Task {
 public static Random random = new Random();
 @Async("taskExecutor")
 public void doTaskOne() throws Exception {
  log.info("开始做任务一");
  long start = System.currentTimeMillis();
  Thread.sleep(random.nextInt(10000));
  long end = System.currentTimeMillis();
  log.info("完成任务一，耗时：" + (end - start) + "毫秒");
 }

 @Async("taskExecutor")
 public void doTaskTwo() throws Exception {
  log.info("开始做任务二");
  long start = System.currentTimeMillis();
  Thread.sleep(random.nextInt(10000));
  long end = System.currentTimeMillis();
  log.info("完成任务二，耗时：" + (end - start) + "毫秒");
 }

 @Async("taskExecutor")
 public void doTaskThree() throws Exception {
  log.info("开始做任务三");
  long start = System.currentTimeMillis();
  Thread.sleep(random.nextInt(10000));
  long end = System.currentTimeMillis();
  log.info("完成任务三，耗时：" + (end - start) + "毫秒");
 }
}

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class ApplicationTests {
 @Autowired
 private Task task;
 @Test
 public void test() throws Exception {
  task.doTaskOne();
  task.doTaskTwo();
  task.doTaskThree();
  Thread.currentThread().join();
 }
}