Java CompletableFuture API Hero Image
December 17, 2019

Java CompletableFuture API: Where Does it Stand in the Asynchronous Java Landscape?

Java Application Development
Java Testing

While the Java CompletableFuture API was an important step for Java support for asynchronous programming, it's only part of the bigger picture.

In this article, we look at the Java CompletableFuture API, what it does, examples of how it works, and how it compares to other asynchronous programming practices in Java today.

Back to top

What Is the Java CompletableFuture API?

The Java CompletableFuture API is a standard Java API for asynchronous programming. It helps developers write code that is more efficient and responsive. 

Introduced in Java 8 back in 2014, the CompletableFuture API was a major step forward for supporting custom callbacks that get executed when the asynchronous operation completes. Unlike its predecessor, the Future.get(), the Java CompletableFuture API was not a blocking call. 

Curious which JDK version your Java development peers are using? Find out in the 2024 Java Developer Productivity Report.

Get your copy

The Reactive Manifesto 

About the same time, the Reactive Manifesto was published (v1.0 in 2013, v2.0 in 2014). It takes asynchronous programming one step further and lays out the guidelines for building fully reactive systems. Reactive Manifesto suggests that a reactive system should be responsive, resilient, elastic, and message driven.

Inspired by the manifesto, the Reactive Streams project defines the interfaces for reactive streams in Java (1.0 released in 2015). Later on, Reactive Streams got standardized and included into the JDK as the Flow API as of Java 9 (2017). Notice that both Reactive Streams and Flow API provide just the interfaces — it is up to reactive frameworks like RxJava or Project Reactor to provide an actual implementation.

These two concepts make up most of the asynchronous programming landscape in Java today.

CompletableFuture API and Reactive Programming Timeline
Back to top

Java CompletableFuture API vs Reactive Streams

How do these two approaches — the Java CompletableFuture API and reactive streams — relate to each other? The main difference is that a CompletableFuture represents one result of an asynchronous call, while Reactive Streams is a pattern for pushing N messages asynchronously through a system. You can say that reactive streams take the same concept and generalize it one step further.

Therefore, CompletableFuture doesn’t (and couldn’t) address the elasticity requirement of the Reactive Manifesto by providing backpressure, as it operates on the level of a single call. For any reactive streams implementation, on the other hand, backpressure is a central concept.

Back to top

What Problems Does Asynchronous Programming Solve?

Let’s take a step back and have a look at the overall benefits of asynchronous programming. Then return to specific technologies and see when you should choose which one.

Asynchronous Remote Server Calls

Unquestionably, the industry is currently moving from monolithic architectures to microservices. When your code makes a call to a remote service, you will not know for sure how quickly the other party will respond. Due to network latency, it will definitely be at least somewhat slower than doing the same work in the local JVM.

It does not make sense to block the server thread until you get the response — threads are an expensive resource. Instead, you can do some other processing for current request while you wait, or serve a different incoming request. Doing the remote service calls asynchronously lets you do just that, helping to get more out of your server resources.

Server Virtualization and Cloud Deployment

Another reality of modern software engineering, usually coming hand-in-hand with microservices, is server virtualization and deployment in the cloud. This builds the case for asynchronous programming even further: when you pay to a 3rd party Infrastructure-as-a-Service provider based on usage, and the cost of spawning an extra instance of each microservice piles up over time, asynchronous programming’s promise to use server resource more effectively starts to look very attractive.

There are other reasons for using asynchronous programming, including better user experience and cleaner code. If the problem at hand is parallel by nature, it is safer and more convenient to use the asynchronous programming tools available, rather than to mess with the Java threads manually.

Back to top

When to Use Java CompletableFutures vs Reactive Streams?

Scenario 1: Single Calls to Microservices

The big plus for the Java CompletableFuture API is that it’s (relatively) simple and available out-of-the-box (part of the JDK).

When your code calls a remote microservice or a slow database to retrieve a specific result to fulfill the current request, it is probably NOT the place to use a reactive stream. One result is all you ever asked for. You are much better off using the methods in the CompletableFuture API to add a custom callback, specifying what to do with the result once it’s ready. In other words, this is a perfect use case for the CompletableFuture API.

Example scenario could be when you need to fetch invoices from 2 different remote systems, then combine the results and take some action on the outcome (e.g. show in the UI).

Java CompletableFuture API Example Path

Scenario 2: A Stream of Asynchronously Processed Data

On the other hand, imagine a scenario where you are truly operating on a stream of messages. Let’s say you have an SMSGateway that receives SMS messages as they come in from users. Each message needs to be processed by SMSProcessor (a remote microservice) and contains a command that takes variable time to execute.

You could implement this scenario based on CompletableFuture API as well, but then you’d be reinventing things like backpressure: what if SMSProcessor is overwhelmed by previous messages, and not yet ready to receive more data? Such streaming scenarios are much better taken care of by the Reactive Streams approach, implemented by frameworks like RxJava or Project Reactor.

CompletableFuture API Example Path

In short, there are use cases for both approaches: single asynchronous operations where CompletableFuture helps to keep things simple, and true streaming scenarios where you’ll want to use reactive streams.

Looking for more ways to add efficiency to your Java development practice? Skip redeploys and increase productivity with JRebel. See for yourself during your 14-day free trial. 

Try JRebel Free

 

Back to top