@Configuration
@EnableAsync
public class ThreadPoolConfig{
 
  //主要任務(wù)的調(diào)度，計(jì)劃執(zhí)行
  @Bean("taskScheduler")
  public Executor createScheduler(){
	    // 創(chuàng)建一個線程池對象
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        // 定義一個線程池大小
        scheduler.setPoolSize(100);
        // 線程池名的前綴
        scheduler.setThreadNamePrefix("taskScheduler-");
        // 設(shè)置線程池關(guān)閉的時候等待所有任務(wù)都完成再繼續(xù)銷毀其他的Bean
        scheduler.setWaitForTasksToCompleteOnShutdown(true);
        // 設(shè)置線程池中任務(wù)的等待時間，如果超過這個時候還沒有銷毀就強(qiáng)制銷毀，以確保應(yīng)用最后能夠被關(guān)閉，而不是阻塞住
        scheduler.setAwaitTerminationSeconds(60);
        // 線程池對拒絕任務(wù)的處理策略,當(dāng)線程池沒有處理能力的時候，該策略會直接在 execute 方法的調(diào)用線程中運(yùn)行被拒絕的任務(wù)；如果執(zhí)行程序已關(guān)閉，則會丟棄該任務(wù)
        scheduler.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
	    return scheduler;
  }

  //主要任務(wù)的執(zhí)行
  @Bean("taskExecutor")
  public Executor createExecutor(){
	    // 創(chuàng)建一個線程池對象
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         //核心線程池大小
        executor.setCorePoolSize(10);
        //最大線程數(shù)
        executor.setMaxPoolSize(30);
        //隊(duì)列容量
        executor.setQueueCapacity(100);
        //活躍時間
        executor.setKeepAliveSeconds(60);
        //線程名字前綴
        executor.setThreadNamePrefix("taskExecutor-");
        // 設(shè)置線程池關(guān)閉的時候等待所有任務(wù)都完成再繼續(xù)銷毀其他的Bean
        executor.setWaitForTasksToCompleteOnShutdown(true);
        // 線程池對拒絕任務(wù)的處理策略,當(dāng)線程池沒有處理能力的時候，該策略會直接在 execute 方法的調(diào)用線程中運(yùn)行被拒絕的任務(wù)；如果執(zhí)行程序已關(guān)閉，則會丟棄該任務(wù)
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
  }

}

@Component
public class TaskComponent{
  @Async("taskExecutor")
  public void doTaskExecutor() {
	System.out.println("任務(wù)開始執(zhí)行?。?！");
  	//具體的執(zhí)行任務(wù)
	//。。。。。。。
  }

//  //有返回值(ObjectVo為自己定義的返回類型)
//@Async("taskExecutor")
//public Future<ObjectVo> doTaskExecutor() {
//	System.out.println("任務(wù)開始執(zhí)行?。?！");
//  	//具體的執(zhí)行任務(wù)
//	//。。。。。。。
//	ObjectVo result=new ObjectVo();
//	return new AsyncResult<>(result);
//}
  @Async("taskScheduler")
  public void doTaskScheduler() {
	System.out.println("任務(wù)開始調(diào)度?。?！");
  	//具體的調(diào)度任務(wù)
	//。。。。。。。
  }

//  //有返回值(ObjectVo為自己定義的返回類型)
//@Async("taskScheduler")
//public Future<ObjectVo> doTaskScheduler() {
//	System.out.println("任務(wù)開始調(diào)度！?。?);
//  	//具體的調(diào)度任務(wù)
//	//。。。。。。。
//	ObjectVo result=new ObjectVo();
//	return new AsyncResult<>(result);
//}
}

@Service
public class UserServiceImpl implements UserService{
  @Autowired
  private TaskComponent taskComponent;
  //測試任務(wù)執(zhí)行與調(diào)用
  @SneakyThrows
  @Override
  public void testTask(){
	//沒有返回值
	taskComponent.doTaskExecutor();
	taskComponent.doTaskScheduler();

	//有返回值
	//Future<ObjectVo> executorResult = taskComponent.doTaskExecutor();
	//Future<ObjectVo> schedulerResult = taskComponent.doTaskScheduler();
	//System.out.println(executorResult.get());
	//System.out.println(schedulerResult.get());
  }
}