CompletableFutures<\/a>\u00a0were introduced in Java 8 (2014).<\/p>\nThe CompletableFuture API is a high-level API for asynchronous programming in Java. This API supports pipelining (also known as chaining or combining) of multiple asynchronous computations into a single result without the mess of nested callbacks (\u201ccallback hell\u201c). This API also is an implementation of the future\/promise concurrency constructs in Java.<\/p>\n
You can use them to tell some worker thread to \u201cgo do some task X, and when you\u2019re done, go do the task Y, i.e. dependent on the result of X\u201d. Using CompletableFutures, you can do something with the result of the previous operation, without actually blocking a thread to wait for the result.<\/p>\n
CompletableFuture class belongs to the java.util.concurrent package.<\/p>\n
![\"\"](\"\/blog\/wp-ttn-blog\/uploads\/2023\/08\/Blog1_1-1.png\")
<\/p>\n
![\"\"](\"\/blog\/wp-ttn-blog\/uploads\/2023\/08\/Blog1_2.png\")
<\/p>\n
The above two future run asynchronously<\/p>\n
![\"\"](\"\/blog\/wp-ttn-blog\/uploads\/2023\/08\/Blog1_3.png\")
<\/p>\n
This shows the blocking nature of Concurrency APIs \u2014 Completable Future<\/p>\n
Therefore, the Completable Future fails for the many transactions per second requests. Example 10K T\/s<\/p>\n
Reactive Programming is the Rescue!<\/strong><\/p>\nReactive programming is a programming paradigm where the focus is on developing asynchronous and non-blocking components<\/strong>. The core of reactive programming is a data stream that we can observe and react to, and even apply back pressure to as well. This leads to non-blocking execution and better scalability with fewer threads of execution.<\/p>\nBlocking calls in any program often\u00a0results in critical resources just waiting for things to happen<\/strong>. These include database calls, calls to web services, and file system calls. If we can free up threads of execution from this waiting and provide a mechanism to circle back once results are available, it\u2019ll yield much better resource utilization.<\/p>\nThis is what adopting the reactive programming paradigm does for us. While it\u2019s possible to switch over to a reactive library for many of these calls, it may not be possible for everything. For us, fortunately, Spring makes it much easier to use reactive programming with MongoDB and REST APIs.<\/p>\n
The four characteristics of a Reactive System are:<\/p>\n
\n- Responsive<\/em><\/strong>: The adoption of the reactive programming paradigm should help us achieve end-to-end non-blocking and, hence, a responsive application.<\/li>\n
- Resilient<\/em><\/strong>: Kubernetes deployment with ReplicaSet of the desired number of pods should provide resilience against random failures.<\/li>\n
- Elastic<\/em><\/strong>: Kubernetes cluster and resources should provide us the necessary support to be elastic in the face of unpredictable loads.<\/li>\n
- Message-Driven<\/em><\/strong>: Having all service-to-service communication handled asynchronously through a Kafka broker should help us here.<\/li>\n<\/ul>\n
Please refer to our blogs for more insightful content and comment if you have any questions regarding the topic.<\/p>\n
<\/div>","protected":false},"excerpt":{"rendered":"
For many use cases, when you have to perform compute-intensive work, make network calls, or execute some parallel processing, we tend to go with multi-threading. Some temporary threads are spawned to process smaller tasks and merged back to the main request thread post-processing. CompletableFutures CompletableFutures\u00a0were introduced in Java 8 (2014). The CompletableFuture API is a […]<\/p>\n","protected":false},"author":1623,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"iawp_total_views":423},"categories":[446],"tags":[5352,1557,4844,5351],"aioseo_notices":[],"_links":{"self":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/58064"}],"collection":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/users\/1623"}],"replies":[{"embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/comments?post=58064"}],"version-history":[{"count":2,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/58064\/revisions"}],"predecessor-version":[{"id":58251,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/posts\/58064\/revisions\/58251"}],"wp:attachment":[{"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/media?parent=58064"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/categories?post=58064"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.tothenew.com\/blog\/wp-json\/wp\/v2\/tags?post=58064"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}