completableFuture.completeExceptionally与引发异常之间的区别

如何解决completableFuture.completeExceptionally与引发异常之间的区别

当我使用completeExceptionally时，我无法阻止运行它的线程继续运行它之后的代码。 如果我在完成之后异常抛出异常，则.get（）将捕获该异常，而不是我在completeExceptionally

中抛出的异常

if(doProcessException){
        log.error("before Completeexceptionally called");
        cf.completeExceptionally(new StepException("Dummy exception thrown in doProcess",new IOException("dummy IOExcetion in dummy step"),this.getStepName()));
        throw new RuntimeException();
    }
logs.error("After Completeexceptionally called,why am i running?);

如果我completeExceptionally不希望代码段中的代码log.error运行...

我希望使用CompletableFuture运行该逻辑的线程停止...

如果我运行上面的代码，则会捕获空的运行时异常，而不是我放入completeExceptionally()

中的详细异常。

如果我什至删除了completeExceptionally()，我最终也会在.get（）上遇到相同的问题

如果是这样，如果我仍然必须处理.get（）异常，completableFuture.exceptionally(() -> {})的目的是什么？

我在completeExceptionally中写的内容都可以放在completableFuture.get()的catch部分中，然后我在可运行对象中抛出一个异常，从而停止了该线程的任何进一步处理。

我可能使用不正确...

编辑： 病情请按评论要求提供更多细节

我的情况有点复杂，因此我想简化一下

我有2层，一个基础层，它使用.thenComposeAsync()方法创建了一系列completableFuture。

在创建链之后，我使用.get(timeout)来阻止我的基础代码，并给整个链超时以完成工作。

这个.get()迫使我尝试像这样

try {
        finalEnrichmentResponse = completableFuture.get(enrichmentTimeoutMs,TimeUnit.MILLISECONDS);
        endResult = finalEnrichmentResponse.getData();
    } catch (InterruptedException e) {
        enrichmentException(enrichmentResponse.getData(),finalEnrichmentResponse,e,"Step chain threw InterruptedException");
    } catch (ExecutionException e) {
        enrichmentException(enrichmentResponse.getData(),"Step chain threw ExecutionException...");
    } catch (TimeoutException e) {
        enrichmentException(enrichmentResponse.getData(),"Step chain exceeded the configured timeout: " + enrichmentTimeoutMs + "ms");
    }

据我了解，这些捕获是如果comletableFuture抛出异常。而且没有一种.exceptionally()方法，出于安全考虑，我认为该方法很好。

现在我的问题开始于我的逻辑层，在那里我为链中的每个“步骤”使用了另一个可完成的未来。

我的链中的步骤正在同步进行。

因此，基本上，我调用返回completableFuture并执行get()这样的步骤的方法

stepResponse = doProcessCf.get();

                } catch (EntityStoppedException e) {
                   //specific handling
                } catch (InterruptedException e) {
                   //specific handling
                } catch (Exception e) {
                   //specific handling
                }

这里我不给出超时，因为如果实际的逻辑超时了，它已经由超时链计算出了...

我知道这种体系结构可能不好，但这是我对可完成期货的第一次尝试。

因为我在逻辑层中没有completableFuture.exceptionally，所以如果对逻辑程序员completeEexceptionally()来说，则catch会处理它。

这可能是我的问题？我需要在该completableFuture中添加一个.exceptionally(() ->{})吗？

无论如何，问题是，如果我从步骤中得到的comepletableFuture在代码completeExceptionally()中执行某处，那么他编写的其余代码仍在运行。

所以也许解决方案只是告诉步骤程序员以某种方式管理他的代码，如果他决定completeExceptionally()，那么他之后不能再运行任何代码了？单点返回式指令。

为简单起见，我们可以假设该链只有1个步骤。

我认为可以用一种更优雅的方式完成。

预先感谢...