BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(10); ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 3, 3, TimeUnit.SECONDS, workQueue, r -> new Thread(r, "sync_export_pool_" + r.hashCode()), (r, executor) -> log.error("隊列已滿拒絕執行")); //異步調用,設置子線程共享 ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes(); //設置子線程共享 RequestContextHolder.setRequestAttributes(servletRequestAttributes, true); threadPool.submit(() -> { //do something log.info("當前線程:{}",Thread.currentThread().getName()); }); threadPool.shutdown();
浙公網安備 33010602011771號