如何在CompletableFuture中使用所需数量的工作线程设置ForkJoinPool。供应商同步（供应商供应商）方法？

Question

据甲骨文说,，

返回一个新的完全未来，该完全未来由ForkJoinPool.common池（）中运行的任务异步完成，该任务的值通过调用给定的供应商获得。

静态CompletableFuture supplyAsync（供应商-供应商，执行者-执行者）返回一个新的CompletableFuture，该新的CompletableFuture由在给定执行者中运行的任务异步完成，其值通过调用给定供应商获得。

如果我使用静态完全未来供应Async（供应商供应商）方法，它默认使用ForkJoinPool.common池（）。这将返回一个ForkJoinpool，其工作线程数等于正在运行的机器中可用的内核数。

但是，我想使用ForkJoinPool和我的自定义工作线程数。使用ForkJoinPool。我不能那样做。

那么，我如何使用我想要的工作线程的数量与我声明的ForkJoinpooluture.supply异步方法？

Answer 1

ForkJoinpool实现Execator。

因此，您可以这样编写代码：

int threadCount = 3;
ForkJoinPool myPool = new ForkJoinPool(threadCount);
CompletableFuture cf = CompletableFuture.supplyAsync(mySup, myPool);