java常用配置类线程池配置<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<全局异常捕捉处理>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>初始化操作

57 阅读 0 评论 38 点赞

我是靠谱客的博主优雅发带，最近开发中收集的这篇文章主要介绍java常用配置类线程池配置<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<全局异常捕捉处理>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>初始化操作，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

线程池配置

@Configuration
public class ExecutorConfig {
    /**
     * 默认线程池线程池
     *
     * @return Executor
     */
    @Bean
    public ThreadPoolTaskExecutor defaultThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //核心线程数目
        executor.setCorePoolSize(1);
        //指定最大线程数
        executor.setMaxPoolSize(10);
        //队列中最大的数目
        executor.setQueueCapacity(3);
        //线程名称前缀
        executor.setThreadNamePrefix("jie-");
        //rejection-policy：当pool已经达到max size的时候，如何处理新任务 //CALLER_RUNS：不在新线程中执行任务，而是由调用者所在的线程来执行 //对拒绝task的处理策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //线程空闲后的最大存活时间
        executor.setKeepAliveSeconds(60);
        //加载
        executor.initialize();
        return executor;
    }
}

线程池使用

注入

   @Autowired
   private ThreadPoolTaskExecutor executorService;

调用

   executorService.submit(() -> {
            try {
          	  	log.info("rn线程:" + Thread.currentThread().getName());
			 } catch (Exception e) {
                e.printStackTrace();
            }
	}

<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<

全局异常捕捉处理

@ControllerAdvice
public class CommonExceptionAdvice {

    private Logger log = LoggerFactory.getLogger(CommonExceptionAdvice.class);
    /**
     * 全局异常捕捉处理
     *
     * @param e
     * @return
     */
    @ResponseBody
    @ExceptionHandler(value = Exception.class)
    public ResponseMessage errorHandler(HttpServletRequest request, Exception e) {
        try {
            e.printStackTrace();
     		log.error(request.getRequestURI() + "::" + e);
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return JsonResult.jsonMsg(GLOBAL_EXCEPTION);
    }
}

>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>

初始化操作

@Component
public class Start implements CommandLineRunner {
    @Override
    public void run(String... args) throws Exception {
            System.out.println("abc");
    }
}