使用CompletableFutures和java时的PlayFramework定制执行器

Question

现在，当我们知道提交给cf的工作是一个长时间运行的IO操作时，我们需要传递一个自定义执行器（否则默认情况下它将在fjp上执行）。

每个控制器执行都有一个HTTP上下文，其中包含所有请求信息。如果使用JPA，EntityManagers······

如果我们只是创建自定义的ExecutorService并将其注入到控制器中，以便在SupplyAsync()中使用，那么我们将不会拥有所有的上下文信息。

下面是返回CompletionStage的某个控制器操作的示例

return supplyAsync(() -> {
   doSomeWork();
}, executors.io); // this is a custom CachedThreadPool with daemon thread factory

}

如果我们尝试在doSomework()中运行类似的内容

Request request = request(); // getting request using Controller.request()

jpa.withTransaction(
    () -> jpa.em() // we will get an exception here although we are wrapped in a transaction
             ...
);

No EntityManager bound to this thread. Try wrapping this call in JPAApi.withTransaction, or ensure that the HTTP context is setup on this thread.

使用CompletableFuture和自定义Executor时，提供所有上下文信息的正确方法是什么？

我还尝试在application.conf中定义自定义执行器，并从actor system中查找它们，但最终会得到MessageDispatcher，尽管它得到了ExecutorService的支持，但它与CompletableFuture不兼容（也许我错了？如果是这样，如何与CF一起使用它？）

Answer 1

您可以使用play.libs.concurrent.HttpExecution.FromThread方法：

在给定的executioncontext上执行工作的executioncontext。当前线程的上下文classloader和http.context将在调用此方法时捕获，并为所有已执行的任务保留此方法。

因此，代码如下所示：

java.util.concurrent.Executor executor = getExecutorFromSomewhere();
return supplyAsync(() -> {
    doSomeWork();
}, play.libs.concurrent.HttpExecution.fromThread(executor));

scala.concurrent.ExecutionContext ec = getExecutorContext();
return supplyAsync(() -> {
    doSomeWork();
}, play.libs.concurrent.HttpExecution.fromThread(ec));