//定時任務代碼
@Scheduled(fixedDelay = 60000)
    public void doSomeThing() {
        servive.doA();
    }
-------------------------------------------
//執(zhí)行定時任務邏輯代碼
@Service
public class Service(){
    @Async("A-config")
    public void doA(){
        //這里執(zhí)行邏輯省略
    }
}
-------------------------------------------
@Bean("updateById")
    public Executor updateById() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 核心線程數(shù)：線程池創(chuàng)建時候初始化的線程數(shù)
        executor.setCorePoolSize(64);
        // 最大線程數(shù)：線程池最大的線程數(shù)，只有在緩沖隊列滿了之后才會申請超過核心線程數(shù)的線程
        executor.setMaxPoolSize(128);
        // 緩沖隊列：用來緩沖執(zhí)行任務的隊列
        executor.setQueueCapacity(500);
        // 允許線程的空閑時間60秒：當超過了核心線程之外的線程在空閑時間到達之后會被銷毀
        executor.setKeepAliveSeconds(60);
        // 線程池名的前綴：設(shè)置好了之后可以方便我們定位處理任務所在的線程池
        executor.setThreadNamePrefix("do-somthing-");
        // 緩沖隊列滿了之后的拒絕策略：這里調(diào)用主線程執(zhí)行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.setWaitForTasksToCompleteOnShutdown(true);
        executor.initialize();
        return executor;
    }

//創(chuàng)建線程池A,這里線程池改造過可以指定名字
NamedThreadPoolExecutor APool =
                new NamedThreadPoolExecutor(
                        32,
                        128,
                        60,
                        TimeUnit.SECONDS,
                        new LinkedBlockingQueue<>(5),
                        new ThreadPoolExecutor.CallerRunsPolicy(),
                        this.getClass().getSimpleName());
-------------------------------------------------------------
//這里拿到任務后，把任務都丟到線程池里去執(zhí)行
List<Object> taskA = getTask();
for(Object task:taskA){
    APool.execute(new CommonRunable(task));
}
//這里調(diào)用shutdown和awaitTermination，并設(shè)置最大超時，在方法執(zhí)行完后就表示任務A已經(jīng)完全執(zhí)行完了
APool.shutdown();
APool.awaitTermination(Long.MAX_VALUE,TimeUnit.NANOSECONDS);
//然后這里A已經(jīng)全部執(zhí)行完了，開始執(zhí)行B
NamedThreadPoolExecutor BPool =
                new NamedThreadPoolExecutor(
                        32,
                        128,
                        60,
                        TimeUnit.SECONDS,
                        new LinkedBlockingQueue<>(5),
                        new ThreadPoolExecutor.CallerRunsPolicy(),
                        this.getClass().getSimpleName());
List<Object> taskB = getTask();
for(Object task:taskB){
    BPool.execute(new CommonRunable(task));
}
//這里調(diào)用shutdown和awaitTermination，并設(shè)置最大超時，在方法執(zhí)行完后就表示任務B已經(jīng)完全執(zhí)行完了,繼續(xù)執(zhí)行后面的任務
BPool.shutdown();
BPool.awaitTermination(Long.MAX_VALUE,TimeUnit.NANOSECONDS);


//繼續(xù)執(zhí)行C任務
...