Java仿Js实现Promise.all实现并行处理的能力

Promise.java

package com.example.demo.util;

import java.util.concurrent.*;

public class Promise {

    // 根据实际情况配置线程池
    static ExecutorService threadPool = new ThreadPoolExecutor(10, 40, 20, TimeUnit.SECONDS, new ArrayBlockingQueue<>(2000), Executors.defaultThreadFactory(), new ThreadPoolExecutor.AbortPolicy());

    public static void allAwait(Runnable ...runnables) throws InterruptedException {
        CountDownLatch checkFinish = new CountDownLatch(runnables.length);
        for (Runnable runnable : runnables) {
            threadPool.execute(()->{
                try {
                    runnable.run();
                } catch(Throwable e) {
                    e.printStackTrace();
                } finally {
                    checkFinish.countDown();
                }
            });
        }
        checkFinish.await();
    }

    public static void all(Runnable ...runnables){
        for (Runnable runnable : runnables) {
            threadPool.execute(runnable);
        }
    }


}

SpringSecurity默认在子线程中无法获取到用户信息，需要配置：
https://stackoverflow.com/questions/3467918/how-to-set-up-spring-security-securitycontextholder-strategy

import javax.annotation.PostConstruct;

import org.springframework.context.annotation.Configuration;
import org.springframework.security.core.context.SecurityContextHolder;

@Configuration
public class SecurityConfig {

  @PostConstruct
  public void enableAuthCtxOnSpawnedThreads() {
    SecurityContextHolder.setStrategyName(SecurityContextHolder.MODE_INHERITABLETHREADLOCAL);
  }
}