@GetMapping("syncSubmit")
public RestResult<String> syncSubmit(String taskName){
    this.executeService.submit(new ParentTask());
    return RestResult.success("提交成功");
}

class ParentTask implements Callable<Boolean>{

    @Override
    public Boolean call() throws Exception {
        Future<A> aFuture = executeService.submit(new FetchAChildTask());
        doSomeThing(500);
        Future<B> bFuture = executeService.submit(new FetchBChildTask());
        doSomeThing(500);
        C c = buildC(aFuture.get(), bFuture.get());
        Future<Boolean> cFuture = executeService.submit(new SaveCChildTask(c));
        return cFuture.get();
    }
}

@Autowired
private GlobalExecuteService executeService;

// 創(chuàng)建新的線程池服務(wù)
@Autowired
private SubExecuteService subExecuteService;

@GetMapping("syncSubmit")
public RestResult<String> syncSubmit(String taskName){
    this.executeService.submit(new ParentTask());
    return RestResult.success("提交成功");
}

class ParentTask implements Callable<Boolean>{

    @Override
    public Boolean call() throws Exception {
        log.info("Begin to Run Parent Task");

        // 向新的線程池服務(wù)提交任務(wù)
        Future<A> aFuture = subExecuteService.submit(new FetchAChildTask());
        doSomeThing(500);

        // 向新的線程池服務(wù)提交任務(wù)
        Future<B> bFuture = subExecuteService.submit(new FetchBChildTask());
        doSomeThing(500);
        C c = buildC(aFuture.get(), bFuture.get());

        // 向新的線程池服務(wù)提交任務(wù)
        Future<Boolean> cFuture = subExecuteService.submit(new SaveCChildTask(c));
        Boolean result = cFuture.get();
        log.info("End to Run Parent Task");
        return result;
    }
}

@Service
public class GlobalExecuteServiceV2 {
    // 記錄當(dāng)前線程運(yùn)行級(jí)別，默認(rèn) 0，表示當(dāng)前線程非該類管理的線程池線程
    private static final ThreadLocal<Integer> LEVEL_HOLDER = ThreadLocal.withInitial(()->0);
    // 一級(jí)線程池
    private ExecutorService executorServiceLeve1;
    // 二級(jí)線程池
    private ExecutorService executorServiceLeve2;
    // 默認(rèn)線程池
    private ExecutorService defExecutorService;

    @PostConstruct
    public void init() {
       // 省略線程池初始化邏輯
    }

    public <T> Future<T> submit(Callable<T> callable){
        // 獲取當(dāng)前線程的運(yùn)行級(jí)別
        Integer level = LEVEL_HOLDER.get();
        // 根據(jù)當(dāng)前運(yùn)行級(jí)別，計(jì)算子任務(wù)所使用的線程池
        ExecutorService executorService = getNextExecutorServiceByLevel(level);
        // 為子任務(wù)分配運(yùn)行級(jí)別
        CallableWrapper<T> callableWrapper = new CallableWrapper<>(level + 1, callable);
        // 提交任務(wù)
        return executorService.submit(callableWrapper);
    }

    private ExecutorService getNextExecutorServiceByLevel(Integer level) {
        if (level == 0){
            return executorServiceLeve1;
        }
        if (level == 1){
            return executorServiceLeve2;
        }
        return defExecutorService;
    }

    class CallableWrapper<T> implements Callable<T>{
        private final Integer level;
        private final Callable<T> callable;

        CallableWrapper(Integer level, Callable<T> callable) {
            this.level = level;
            this.callable = callable;
        }

        @Override
        public T call() throws Exception {
            try {
                // 為線程池綁定運(yùn)行級(jí)別
                LEVEL_HOLDER.set(level);
                return callable.call();
            }finally {
                // 清理線程池運(yùn)行級(jí)別
                LEVEL_HOLDER.remove();
            }
        }
    }
}