动态设置线程池大小的完成阶段在发挥！用Akka

Question

在我的web应用程序中，我正在使用Play！构建在Akka基础上的用于管理线程的框架。在一个特定的案例中，我组合了许多从外部服务收集数据的CompletionStages，我希望控制并行请求的数量，以便不使那些外部服务负担过重。在不更改整个应用程序的情况下做到这一点的一种方法是控制Akka使用的线程池大小。现在我在akka like中准备了两个线程池，并尝试在这两个池之间进行切换。我正在使用下面这样的内容来编写我的CompletionStages：

CompletableFuture.completedFuture(firstResult)
                        .thenComposeAsync( firstResult -> { dostuff(firstResult);}

根据Akka的文档，这是如何设置当前线程池的：

// this is scala.concurrent.ExecutionContext
// for use with Futures, Scheduler, etc.
final ExecutionContext ex = system.dispatchers().lookup("my-dispatcher");

Answer 1

您需要将自定义的执行器传递给thencomposeasync方法：

final java.util.concurrent.Executor exec = system.dispatchers().lookup("my-dispatcher");

CompletableFuture.completedFuture(firstResult)
                 .thenComposeAsync(firstResult -> {
                   dostuff(firstResult);
                 }, exec);