#****************集成Async線(xiàn)程池開(kāi)始*******************
async: # Async線(xiàn)程池 配置
 executor:
  corepoolsize: 20
  maxpoolsize: 25
  queuecapacity: 40
  keepaliveseconds: 200
  threadnameprefix: appasync
  awaitterminationseconds: 60
#*****************集成Async線(xiàn)程池結(jié)束******************

@Configuration
@EnableAsync
public class ExecutorConfig {

  @Value("${async.executor.corepoolsize}")
  private Integer corePoolSize;

  @Value("${async.executor.maxpoolsize}")
  private Integer maxPoolSize;

  @Value("${async.executor.queuecapacity}")
  private Integer queueCapacity;

  @Value("${async.executor.keepaliveseconds}")
  private Integer keepAliveSeconds;

  @Value("${async.executor.threadnameprefix}")
  private String threadNamePrefix;

  @Value("${async.executor.awaitterminationseconds}")
  private Integer awaitTerminationSeconds;

  /**
   * 線(xiàn)程池
   *
   * @return
   */
  @Bean(name = "asyncExecutor")
  public Executor asyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    // 基礎(chǔ)線(xiàn)程數(shù) corePoolSize: 10
    executor.setCorePoolSize(corePoolSize);
    // 最大線(xiàn)程數(shù) maxPoolSize: 15
    executor.setMaxPoolSize(maxPoolSize);
    // 隊(duì)列長(zhǎng)度 queueCapacity: 25
    executor.setQueueCapacity(queueCapacity);
    // 線(xiàn)程池維護(hù)線(xiàn)程所允許的空閑時(shí)間,單位為秒 keepAliveSeconds: 200
    executor.setKeepAliveSeconds(keepAliveSeconds);
    // 線(xiàn)程名字 threadNamePrefix: appasync
    executor.setThreadNamePrefix(threadNamePrefix);
    executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
    // 等待所有任務(wù)都完成再繼續(xù)銷(xiāo)毀其他的Bean
    executor.setWaitForTasksToCompleteOnShutdown(true);
    // 線(xiàn)程池中任務(wù)的等待時(shí)間，如果超過(guò)這個(gè)時(shí)候還沒(méi)有銷(xiāo)毀就強(qiáng)制銷(xiāo)毀，以確保應(yīng)用最后能夠被關(guān)閉，而不是阻塞住
    executor.setAwaitTerminationSeconds(awaitTerminationSeconds);
    executor.initialize();
    return executor;
  }
}

@RestController
@Slf4j
@RequestMapping("/pubapi/asyncExecutor")
public class AsyncExecutorController extends BaseController {

  @Resource(name = "asyncExecutor")
  private Executor asyncExecutor;

  @PostMapping("/monitor")public ResultBean<Map<String, Object>> getAsyncExecutorData() {
    ResultBean<Map<String, Object>> resultBean = ResultBeanUtil.error500();
    if (asyncExecutor == null) {
      return resultBean;
    }

    try {
      ThreadPoolTaskExecutor executorTask = (ThreadPoolTaskExecutor) asyncExecutor;
      ThreadPoolExecutor executor = executorTask.getThreadPoolExecutor();

      // 當(dāng)前排隊(duì)線(xiàn)程數(shù)
      int queueSize = executor.getQueue().size();
      // 當(dāng)前活動(dòng)線(xiàn)程數(shù)
      int activeCount = executor.getActiveCount();
      // 執(zhí)行完線(xiàn)程數(shù)
      long completedThreadCount = executor.getCompletedTaskCount();
      // 總線(xiàn)程數(shù)
      long taskCount = executor.getTaskCount();
      // 初始線(xiàn)程數(shù)
      int poolSize = executor.getPoolSize();
      // 核心線(xiàn)程數(shù)
      int corePoolSize = executor.getCorePoolSize();
      // 線(xiàn)程池是否終止
      boolean isTerminated = executor.isTerminated();
      // 線(xiàn)城池是否關(guān)閉
      boolean isShutdown = executor.isShutdown();
      // 線(xiàn)程空閑時(shí)間
      long keepAliveTime = executor.getKeepAliveTime(TimeUnit.MILLISECONDS);
      // 最大允許線(xiàn)程數(shù)
      long maximumPoolSize = executor.getMaximumPoolSize();
      // 線(xiàn)程池中存在的最大線(xiàn)程數(shù)
      long largestPoolSize = executor.getLargestPoolSize();

      Map<String, Object> threadPoolData = new HashMap<>(18);
      threadPoolData.put("當(dāng)前排隊(duì)線(xiàn)程數(shù)", queueSize);
      threadPoolData.put("當(dāng)前活動(dòng)線(xiàn)程數(shù)", activeCount);
      threadPoolData.put("執(zhí)行完線(xiàn)程數(shù)", completedThreadCount);
      threadPoolData.put("總線(xiàn)程數(shù)", taskCount);
      threadPoolData.put("初始線(xiàn)程數(shù)", poolSize);
      threadPoolData.put("核心線(xiàn)程數(shù)", corePoolSize);
      threadPoolData.put("線(xiàn)程池是否終止", isTerminated);
      threadPoolData.put("線(xiàn)城池是否關(guān)閉", isShutdown);
      threadPoolData.put("線(xiàn)程空閑時(shí)間", keepAliveTime);
      threadPoolData.put("最大允許線(xiàn)程數(shù)", maximumPoolSize);
      threadPoolData.put("線(xiàn)程池中存在的最大線(xiàn)程數(shù)", largestPoolSize);

      InetAddress inetAddress = IdWorker.getLocalHostLANAddress();
      Map<String, Object> resultData = new HashMap<>(4);
      resultData.put("ip", inetAddress.getHostAddress());
      resultData.put("threadPoolData", threadPoolData);

      resultBean = ResultBeanUtil.success("請(qǐng)求成功！", resultData);
    } catch (Exception e) {
      e.printStackTrace();
    }
    return resultBean;
  }

}

public void getMap(){
    /**
     * 先將耗時(shí)的、相互之間無(wú)依賴(lài)的操作先執(zhí)行，由于其執(zhí)行結(jié)果暫時(shí)不是特別關(guān)注，所以
     */
    Future<String> futureA = functionA();
    Future<String> futureB = functionB();
    /**
     * 執(zhí)行其他的操作，其實(shí)functionA(),functionB()也在工作
     */
    aaa();
    /**
     * 獲取異步的結(jié)果，然后計(jì)算
     */
    try {
      String resultA =futureA.get();
      String resuleB = futureB.get();
    } catch (InterruptedException e) {
      e.printStackTrace();
    } catch (ExecutionException e) {
      e.printStackTrace();
    }
    
  }

  public Future<String> functionA (){
    Future<String> future = null;
    try {
      Thread.sleep(5000);
      future = new AsyncResult<String>("functionA");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return future;
  }

  public Future<String> functionB (){
    Future<String> future = null;
    try {
      Thread.sleep(3000);
      future = new AsyncResult<String>("functionB");
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    return future;
  }

  public void aaa(){
    System.out.println("我是");
  }