具有自定义分叉连接池的 Spring Boot

juzqafwq  于 2022-12-21  发布在  Spring
关注(0)|答案(1)|浏览(115)

我正在尝试使用一个自定义的fork连接池(从任务排队线程继承slf4j的MDC上下文),并希望将其集成到一个spring Boot 应用程序中,然后将其与CompletableFutures一起使用。
我怎样告诉spring我想使用我的fork加入池?
谢啦,谢啦

xqnpmsa8

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

相关问题