package cn.bwjf.config;


import cn.bwjf.common.constant.InitServiceIdEnum;
import cn.bwjf.common.tools.InitServiceUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;

/**
 * @description : 異常捕獲配置類
 * @author : tizzy <br/>
 * @version : 1.0
 * @date 2019/9/21
 */
@Configuration
@Slf4j
public class AsyncExceptionConfig implements AsyncConfigurer {
 
 
 
 /**
 * @description : 設置異步方法線程參數(shù)
 * @author : tizzy
 * @version : 1.0
 */
 @Bean
 @Override
 public Executor getAsyncExecutor() {
 ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
 //根據(jù)自己機器配置
 executor.setCorePoolSize(8);
 executor.setMaxPoolSize(16);
 executor.setQueueCapacity(64);
 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
  executor.setThreadNamePrefix("SpringAsyncThread-");
 
  return executor;
 }

 @Override
 public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
 return new SpringAsyncExceptionHandler();
 }

 class SpringAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
 @Override
 public void handleUncaughtException(Throwable throwable, Method method, Object... objects) {
 log.info("------我是Async無返回方法的異常處理方法---------");

 //通過反射獲取各個初始化方法名字
 String methodName = method.getName();
 log.info(" 當前異常方法名 == {} " , methodName);
 
 //根據(jù)方法名字 記錄異常 略。。。。

 log.info("------我是Async無返回方法的異常處理方法---------");
 }
 }
}

@Async 
public Future<String> asyncMethod() { 
 
 try { 
 Thread.sleep(5000); 
 return new AsyncResult<String>("hello world !!!!"); 
 } catch (InterruptedException e) { 
 // 
 } 
 
 return null; 
} 

 try {
 Future future = service.asyncMethod();
 future.get();
 } catch (ExecutionException e) {
 logger.error("exception occurs", e);
 } catch (InterruptedException e) {
 logger.error("exception occurs", e);
 }

public interface Future<V> {

 boolean cancel(boolean mayInterruptIfRunning);
 boolean isCancelled();
 boolean isDone();

 V get() throws InterruptedException, ExecutionException;
 V get(long timeout, TimeUnit unit)
 throws InterruptedException, ExecutionException, TimeoutException;

}