java - 如何为 CompletableFuture::supplyAsync 选择执行器

Question

CompletableFuture::supplyAsync(() -> IO 绑定(bind)查询)

我如何为 CompletableFuture::supplyAsync 选择执行器以避免污染 ForkJoinPool.commonPool()。

Executors中有很多选项(newCachedThreadPool、newWorkStealingPool、newFixedThreadPool等)

我读到了新的 ForkJoinPool here

如何为我的用例选择合适的？

Answer 1

你应该使用 public static <U> CompletableFuture<U> supplyAsync(Supplier<U> supplier, Executor executor)方法。作为执行者，您可以使用 Executors.new 中的任何一个.. - 这取决于您的需要。最好使用 newFixedThreadPool() 而不是 newCachedThreadPool()，因为 newCachedThreadPool() 会导致性能问题，从而导致创建多个线程甚至抛出 OutOfMemoryError。这是一个非常好的article有很好的例子。