Perché Java 8 CompletableFuture thenCompose genera un'eccezione diversa in base all'ordine di completamento?

Question

Ho riscontrato uno strano comportamento del metodo CompletableFuture thenCompose di Java 8. Ho due test che differiscono solo in ordine di esecuzione. Entrambi i test simulano il fallimento di CompletableFuture generato in thenCose.

@Test 
public void completedAfter() { 
    CompletableFuture<String> future1 = new CompletableFuture<>(); 
    CompletableFuture<String> future2 = new CompletableFuture<>(); 

    future1.thenCompose(x -> future2).whenComplete((r, e) -> System.out.println("After: " + e)); 

    future1.complete("value"); 
    future2.completeExceptionally(new RuntimeException()); 
} 

@Test 
public void completedBefore() { 
    CompletableFuture<String> future1 = new CompletableFuture<>(); 
    CompletableFuture<String> future2 = new CompletableFuture<>(); 

    future1.complete("value"); 
    future2.completeExceptionally(new RuntimeException()); 

    future1.thenCompose(x -> future2).whenComplete((r, e) -> System.out.println("Before: " +e)); 
} 

L'output è:

After: java.util.concurrent.CompletionException: java.lang.RuntimeException 
Before: java.lang.RuntimeException 

La domanda è: perché è l'eccezione avvolto in CompletionException in un caso ma non nell'altro?

Aggiornamento: Here è un bug report correlato. È stato contrassegnato e risolto come un bug in JDK.

Answer 1

Sembra un errore nella libreria jdk.

Nel caso "Dopo", .thenCompose aggiunge un nodo di completamento ThenCopy al futuro di destinazione, la cui esecuzione viene successivamente attivata da .completeExceptionally. Il metodo run del nodo di completamento trova l'eccezione nel futuro e chiama .internalComplete nella destinazione, che include tutte le eccezioni in CompletionException. Vedere here come viene creato il nodo e here per il punto in cui avviene il wrapping.

Ora, nel caso Before, il percorso del codice è completamente diverso. Poiché il futuro è già completato, .thenCompose non crea nodi aggiuntivi, ma il richiamo immediato è invokes e restituisce semplicemente un (già completato secondo futuro), sul quale si chiama quindi .whenComplete, che, ancora una volta, non si preoccupa di creare un nuovo nodo di completamento, ma semplicemente invokes the callback, dandogli l'eccezione originale dal secondo futuro.

ragazzo, guardando a questo codice, ci sono tanti esempi che voglio mostrare ai miei studenti di ciò che non dovrebbe mai fare ...