Java CompletableFuture: A Deep Dive 🎯

Welcome to your comprehensive guide on Java's CompletableFuture! In this lesson, we'll explore this powerful tool that simplifies asynchronous programming and improves efficiency. Let's dive right in! 🐳

Understanding CompletableFuture 💡

CompletableFuture is a utility class in Java 8 and later versions that represents the result of an asynchronous computation. It's a promise of a supply of a result, either a value or an exception.

java

CompletableFuture<Void> task = CompletableFuture.runAsync(() -> {
    // Asynchronous task code here
});

📝 Note: CompletableFuture can be used for both computation and I/O operations.

Creating and Managing CompletableFutures 💡

We can create a CompletableFuture in three ways:

CompletableFuture.supplyAsync(): returns a new CompletableFuture representing the result of an asynchronous computation.
CompletableFuture.runAsync(): runs an asynchronous task that may throw an exception.
CompletableFuture.completedFuture(): returns a CompletableFuture that completes with a given value or an exception.

Examples 💡

Example 1: Simple Computation

java

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    // Perform a computation
    Thread.sleep(2000);  // Simulate a long computation
    return 42;
});

// Continue with other code

Example 2: Reading a File

java

Path path = Paths.get("example.txt");
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    try (BufferedReader reader = Files.newBufferedReader(path)) {
        return reader.lines().reduce("", String::concat);
    } catch (IOException e) {
        throw new RuntimeException(e);
    }
});

// Continue with other code

Combining CompletableFutures 💡

We can combine multiple CompletableFutures using methods like thenApply(), thenAccept(), thenRun(), and thenCombine(). These methods are called when the initial CompletableFuture completes.

Example 💡

java

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> 1);
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 2);

CompletableFuture.allOf(future1, future2)
    .thenApply((ignored) -> future1.join() + future2.join());

Exceptions and Error Handling 💡

Exceptions in CompletableFuture are handled using methods like exceptionally() and handle().

Example 💡

java

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    throw new RuntimeException("Oops!");
});

future.exceptionally((ex) -> {
    System.err.println("Error occurred: " + ex.getMessage());
    return 0;
});

Java CompletableFuture: A Deep Dive 🎯

Java CompletableFuture: A Deep Dive 🎯

Understanding CompletableFuture 💡

Creating and Managing CompletableFutures 💡

Examples 💡

Example 1: Simple Computation

Example 2: Reading a File

Combining CompletableFutures 💡

Example 💡

Exceptions and Error Handling 💡

Example 💡

Quiz 📝