springboot使用线程池（@EnableAsync和@Async）

package com.neusoft.app.etlTask;  import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;  import java.util.concurrent.Executor; import java.util.concurrent.ThreadPoolExecutor;  @Configuration @EnableAsync public class ExecutorConfig {   /** Set the ThreadPoolExecutor's core pool size. */  private int corePoolSize = 5;  /** Set the ThreadPoolExecutor's maximum pool size. */  private int maxPoolSize = 15;  /** Set the capacity for the ThreadPoolExecutor's BlockingQueue. */  private int queueCapacity = 100;   @Bean  public Executor taskAsync() {  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  executor.setCorePoolSize(corePoolSize);  executor.setMaxPoolSize(maxPoolSize);  executor.setQueueCapacity(queueCapacity);  executor.setThreadNamePrefix("TaskExecutor-");   // rejection-policy：当pool已经达到max size的时候，如何处理新任务  // CALLER_RUNS：不在新线程中执行任务，而是有调用者所在的线程来执行  executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  executor.initialize();  return executor;  } } 

@Component public class EtlTools {  @Async  public void trans(int i){  SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");  try {  Thread.sleep(10000);  System.out.println("执行任务"+i+"  "+Thread.currentThread().getName()+"  "+format.format(new Date()));  } catch (InterruptedException e) {  e.printStackTrace();  }  } }

@Autowired private EtlTools etlTools;  @GetMapping("/test") @ResponseBody public void test(){  for (int i = 0; i < 10; i++) {  etlTools.trans(i);  }  //立即返回，此时后台任务并未结束，刚刚开始。 }