Transform Java Future into a CompletableFuture

by

If the library you want to use also offers a callback style method in addition to the Future style, you can provide it a handler that completes the CompletableFuture without any extra thread blocking. Like so:

    AsynchronousFileChannel open = AsynchronousFileChannel.open(Paths.get("/some/file"));
    // ... 
    CompletableFuture<ByteBuffer> completableFuture = new CompletableFuture<ByteBuffer>();
    open.read(buffer, position, null, new CompletionHandler<Integer, Void>() {
        @Override
        public void completed(Integer result, Void attachment) {
            completableFuture.complete(buffer);
        }

        @Override
        public void failed(Throwable exc, Void attachment) {
            completableFuture.completeExceptionally(exc);
        }
    });
    completableFuture.thenApply(...)

Without the callback the only other way I see solving this is to use a polling loop that puts all your Future.isDone() checks on a single thread and then invoking complete whenever a Future is gettable.

More Related Contents:

  1. Should Java 8 getters return optional type?
  2. Convert Iterable to Stream using Java 8 JDK
  3. Java 8 Streams: multiple filters vs. complex condition
  4. Java 8 stream reverse order
  5. Partition a Java 8 Stream
  6. Convert from List to CompletableFuture
  7. Lambda ‘special void-compatibility rule’ – statement expression
  8. Instance Method Reference and Lambda Parameters
  9. How do I keep the iteration order of a List when using Collections.toMap() on a stream?
  10. Why is this java Stream operated upon twice?
  11. Modifying local variable from inside lambda
  12. Unable to obtain ZonedDateTime from TemporalAccessor using DateTimeFormatter and ZonedDateTime in Java 8
  13. Why is Files.lines (and similar Streams) not automatically closed?
  14. In Java 8, why is the default capacity of ArrayList now zero?
  15. Why are class static methods inherited but not interface static methods?
  16. Why does this java 8 stream operation evaluate to Object instead of List or just List?
  17. Optional vs. null. What is the purpose of Optional in Java 8? [duplicate]
  18. In Stream reduce method, must the identity always be 0 for sum and 1 for multiplication?
  19. How do I access a UI element from another controller class in JavaFX?
  20. Can program developed with Java 8 be run on Java 7?
  21. Comparator.comparing(…) of a nested field
  22. Variable is already defined in method lambda
  23. Using JavaFX in JRE 8, “Access restriction” error
  24. Why Functional Interfaces in Java 8 have one Abstract Method?
  25. Annotating the functional interface of a Lambda Expression
  26. Java Lambda expressions [closed]
  27. How to set IntelliJ IDEA Project SDK
  28. Consumer mapped Class in HashMap
  29. Get last element of Stream/List in a one-liner
  30. Java 8 Supplier Exception handling with CompletableFuture

Leave a Comment