将CompletableFuture与EJb一起使用时撞墙

我试图将CompletableFuture与在WildFly上运行的EBJ bean一起使用。

我可以看到调试器到达了远程Ejb并成功检索了结果,但是在向调用方类的Wayback中我遇到了异常

  

java.lang.ClassnotFoundException:没有可用的类加载器

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)]
tao199107 回答:将CompletableFuture与EJb一起使用时撞墙

我想这与使用默认的ForkJoinPool的事实有关。基本上,在JEE服务器中创建非托管线程不是一个好主意(甚至被规范禁止)。 一种可能是使用JEE的ManagedExecutorService并像这样注入它:

@Resource
private ManagedExecutorService mes;

然后您可以将其用作supplyAsync调用的第二个参数:

final CompletableFuture<Void> future =
    CompletableFuture.supplyAsync(() -> {
        //...
    },mes).thenAccept//...

另请参阅:

Which thread executes CompletableFuture's tasks and callbacks?

Java 8 CompletableFuture Example

本文链接:https://www.f2er.com/3057896.html

大家都在问