ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10);
executor.setMaxPoolSize(20);
executor.setQueueCapacity(200);
executor.setKeepAliveSeconds(60);
executor.setThreadNamePrefix("kelingExecutor-");
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
executor.initialize();

public static int clientTotal = 5000;
for (int i = 0; i < clientTotal ; i++) {
	executor.execute(() -> update());
}
//此处的lambada是它的缩写
/*
executor.execute(new Runnable() {
    @Override
    public void run() {
        update();
    }
});  
*/

@Slf4j
public class JodaTime1 {

    /**
     * 请求总数
     */
    public static int clientTotal = 5000;
  
    /**
     * joda-time类。线程安全
     */
    private static DateTimeFormatter dateTimeFormatter = DateTimeFormat.forPattern("yyyyMMdd");

    public static void main(String[] args) {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(200);
        executor.setKeepAliveSeconds(60);
        executor.setThreadNamePrefix("kelingExecutor-");
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();

        for (int i = 0; i < clientTotal ; i++) {
            final int count = i;
            executor.execute(() ->update(count));
        }
    }
    private static void update(int i) {
        log.info("{},{}",i, DateTime.parse("20180208", dateTimeFormatter).toDate() );
    }


}

@Component
public class MyInterceptor implements HandlerInterceptor {
    
    /**
     * 是否拦截请求，返回false就被拦截。就不会到postHandle和afterCompletion
     */
    @Override
    public boolean preHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o) throws Exception {
        System.out.println("执行到了preHandle");
        return false;
    }

    /**
     * 请求从controller到视图之间执行，一般用作添加东西返回给视图
     */
    @Override
    public void postHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, ModelAndView modelAndView) throws Exception {

        System.out.println("执行到了postHandle");
    }

    /**
     * 请求结束时执行，一般用作资源销毁，不常用
     */
    @Override
    public void afterCompletion(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, Exception e) throws Exception {
        System.out.println("执行到了afterCompletion");

    }
}

@Configuration
public class MyWebMvcConfig implements WebMvcConfigurer  {
    /**
     * WebMvcConfigurerAdapter只是对WebMvcConfigurer接口的空实现，而且已经废弃，所以自己实现
     * 貌似要全部实现
     */
    
    @Autowired
    private MyInterceptor myInterceptor;

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(myInterceptor).addPathPatterns("/**");
    }
    
    //... ...
    
}

@Override
public boolean preHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o) throws Exception {
    //请求乱码
    httpServletRequest.setCharacterEncoding("utf-8");
    //校验登录或者权限
    if (httpServletRequest.getAttribute("user") == null) {
        httpServletRequest.getRequestDispatcher("/login.jsp").forward(httpServletRequest, httpServletResponse);
        return false;
    }
    return true;
}

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler)

//手动创建和Executors的工厂创建，创建过程不一样，创建后的使用是一样的。
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 200, 0L,
                TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<>(1024),
                (r) -> {
                    Thread t = new Thread(r);
                    System.out.println("生成线程 " + t);
                    return t;
                });