Java 8 Supplier Exception handling with CompletableFuture

by

The factory methods using the standard functional interfaces aren’t helpful when you want to handle checked exceptions. When you insert code catching the exception into the lambda expression, you have the problem that the catch clause needs the CompletableFuture instance to set the exception while the factory method needs the Supplier, chicken-and-egg.

You could use an instance field of a class to allow mutation after creation, but in the end, the resulting code isn’t clean and more complicated that a straight-forward Executor-based solution. The documentation of CompletableFuture says:

So you know the following code will show the standard behavior of CompletableFuture.supplyAsync(Supplier) while handling checked exceptions straight-forward:

CompletableFuture<Integer> f=new CompletableFuture<>();
ForkJoinPool.commonPool().submit(()-> {
  try { f.complete(SupplyNumbers.sendNumbers()); }
  catch(Exception ex) { f.completeExceptionally(ex); }
});

The documentation also says:

… To simplify monitoring, debugging, and tracking, all generated asynchronous tasks are instances of the marker interface CompletableFuture.AsynchronousCompletionTask.

If you want to adhere to this convention to make the solution even more behaving like the original supplyAsync method, change the code to:

CompletableFuture<Integer> f=new CompletableFuture<>();
ForkJoinPool.commonPool().submit(
  (Runnable&CompletableFuture.AsynchronousCompletionTask)()-> {
    try { f.complete(SupplyNumbers.sendNumbers()); }
    catch(Exception ex) { f.completeExceptionally(ex); }
});

More Related Contents:

  1. Convert from List to CompletableFuture
  2. Why can’t I throw an exception in a Java 8 lambda expression? [duplicate]
  3. CompletableFuture recoverWith equivalent? i.e. exceptionally but return CompletableFuture
  4. Why does a Java Lambda which throws a Runtime Exception require brackets?
  5. NumberFormatException not wrking java
  6. Understanding checked vs unchecked exceptions in Java
  7. PermGen elimination in JDK 8
  8. Is method reference caching a good idea in Java 8?
  9. Java 8: Lambda-Streams, Filter by Method with Exception
  10. How to convert a Java 8 Stream to an Array?
  11. Should you report the message text of exceptions?
  12. In Java 8, is there a ByteStream class?
  13. Sum values from specific field of the objects in a list
  14. How do I define a method which takes a lambda as a parameter in Java 8?
  15. What’s the difference between instance method reference types in Java 8?
  16. functional interface that takes nothing and returns nothing [duplicate]
  17. EOFException – how to handle?
  18. Formatting a Duration in Java 8 / jsr310
  19. Most efficient way to get the last element of a stream
  20. Why does findFirst() throw a NullPointerException if the first element it finds is null?
  21. Java 8 Stream IllegalStateException: Stream has already been operated on or closed
  22. How to sum values in a Map with a stream?
  23. Java ArrayIndexOutOfBounds Exception
  24. Why can we use ‘this’ as an instance method parameter?
  25. When and why would you use Java’s Supplier and Consumer interfaces?
  26. Java interface throws an exception but interface implementation does not throw an exception?
  27. Implied anonymous types inside lambdas
  28. java.lang.ClassNotFoundException:com.mysql.jdbc.Driver [duplicate]
  29. No Such Element Exception?
  30. Stream.peek() method in Java 8 vs Java 9

Leave a Comment