<dependency>
   <groupId>com.alibaba</groupId>
   <artifactId>transmittable-thread-local</artifactId>
   <version>2.11.4</version>
</dependency>

private static final TransmittableThreadLocal<User> CURRENT_USER_HOLDER = new TransmittableThreadLocal();

@Bean(value = "defaultThreadPool")
    public Executor buildQueueThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        int cpuNum = Runtime.getRuntime().availableProcessors();
        // 設(shè)置核心線程數(shù)
        executor.setCorePoolSize(Math.min(cpuNum * 2, 16));
        // 設(shè)置最大線程數(shù)
        executor.setMaxPoolSize(cpuNum * 2);
        //隊列中最大的數(shù)目
        executor.setQueueCapacity(300);
        //線程名稱前綴
        executor.setThreadNamePrefix("defaultThreadPool_");
        //rejection-policy：當pool已經(jīng)達到max size的時候，如何處理新任務(wù)
        //CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線程來執(zhí)行
        //對拒絕task的處理策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //線程空閑后的最大存活時間
        executor.setKeepAliveSeconds(60);
        //加載
        executor.initialize();
        return TtlExecutors.getTtlExecutor(executor);
    }