我正在尝试将 CompletableFuture 与在 WildFly 上运行的 EBJ bean 结合使用。
我可以看到调试器到达远程 Ejb 并成功检索结果,但在调用方类的 Wayback 中我遇到了异常
java.lang.ClassNotFoundException: No classloader available
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
dnsRecords = ipaFacadeService.fetchDnsRecords();
return dnsRecords;
}).thenAccept(result -> {
if (result.size() > 0) {
//do more stuff with the result
}
});
future.get();
当我堆栈跟踪异常时,我发现它与 CompletableFuture.supplyAsync() 使用的 ForkJoin 有关
[org.jboss.ejb.client.EJBInvocationHandler.doInvoke(EJBInvocationHandler.java:238),
org.jboss.ejb.client.EJBInvocationHandler.doInvoke(EJBInvocationHandler.java:183),
org.jboss.ejb.client.EJBInvocationHandler.invoke(EJBInvocationHandler.java:146),
com.sun.proxy.$Proxy107.fetchDnsRecords(Unknown Source), no.lyse.tele.prov.struts2.action.network.DnsAction.lambda$list$1(DnsAction.java:150),
java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590),
java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1582),
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289),
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056),
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692),
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)]
最佳答案
我想这与使用默认的 ForkJoinPool 的事实有关。基本上在 JEE 服务器内部创建非托管线程不是一个好主意(甚至被规范禁止)。 一种可能性是使用 JEE 的 ManagedExecutorService并像这样注入(inject):
@Resource
private ManagedExecutorService mes;
然后您可以将其用作 SupplyAsync 调用的第二个参数:
final CompletableFuture<Void> future =
CompletableFuture.supplyAsync(() -> {
//...
}, mes).thenAccept//...
另请参阅:
Which thread executes CompletableFuture's tasks and callbacks?
关于java - 将 CompletableFuture 与 EJb 结合使用时遇到困难,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/58975768/