我正在尝试使用一个自定义的fork连接池(从任务排队线程继承slf4j的MDC上下文),并希望将其集成到一个spring Boot 应用程序中,然后将其与CompletableFutures一起使用。我怎样告诉spring我想使用我的fork加入池?谢啦,谢啦
xqnpmsa81#
我最终做的是使用一个静态方法:
public static <U> CompletableFuture<U> supplyAsyncWithMdcContext(Supplier<U> supplier) { return supplyAsync(supplier, workerPool); }
其中workerPool参数:
static final ForkJoinPool workerPool = new MdcForkJoinPool(Runtime.getRuntime().availableProcessors(), ForkJoinPool.defaultForkJoinWorkerThreadFactory, null, false);
现在,当我想使用is而不是supplyAsync时,我会使用supplyAsyncWithMdcContext
supplyAsync
supplyAsyncWithMdcContext
1条答案
按热度按时间xqnpmsa81#
我最终做的是使用一个静态方法:
其中workerPool参数:
现在,当我想使用is而不是
supplyAsync
时,我会使用supplyAsyncWithMdcContext