Отдельная обработка исключений из CompletableFuture

Question

Я понимаю, что я бы хотел, чтобы потребители нашего API не должны обрабатывать исключение. Или, возможно, более четко я хотел бы гарантировать, что исключение всегда регистрируется, но только потребитель будет знать, как справиться с успехом. Я хочу, чтобы клиент мог справиться с этим исключением, если они этого захотят, нет действительного File, чтобы я мог вернуться к ним.

примечания: FileDownload является Supplier<File>

@Override 
public CompletableFuture<File> processDownload(final FileDownload fileDownload) { 
    Objects.requireNonNull(fileDownload); 
    fileDownload.setDirectory(getTmpDirectoryPath()); 
    CompletableFuture<File> future = CompletableFuture.supplyAsync(fileDownload, executorService); 
    future... throwable -> { 
     if (throwable != null) { 
      logError(throwable); 
     } 
     ... 
     return null; // client won't receive file. 
    }); 
    return future; 

} 

Я не очень понимаю CompletionStage вещей. Использую ли я exception или handle? вернуть первоначальное будущее или будущее, которое они возвратят?

Answer 1

Предполагая, что вы не хотите, чтобы повлиять на результат вашего CompletableFuture, вы хотите использовать CompletableFuture::whenComplete:

future = future.whenComplete((t, ex) -> { 
    if (ex != null) { 
    logException(ex); 
    } 
}); 

Теперь, когда потребитель вашего API пытается вызвать future.get(), они получат исключение , но им необязательно что-то делать с этим.

---

Однако, если вы хотите сохранить потребителя неведении, за исключением (возврат null когда fileDownload терпит неудачу), вы можете использовать либо CompletableFuture::handle или CompletableFuture::exceptionally:

future = future.handle((t, ex) -> { 
    if (ex != null) { 
    logException(ex); 
    return null; 
    } else { 
    return t; 
    } 
}); 

или

future = future.exceptionally(ex -> { 
    logException(ex); 
    return null; 
});