{"id":329573,"date":"2024-05-22T19:40:00","date_gmt":"2024-05-22T19:40:00","guid":{"rendered":"https:\/\/www.baeldung.com\/completablefuture-vs-mono"},"modified":"2024-05-22T19:40:00","modified_gmt":"2024-05-22T19:40:00","slug":"completablefuture-vs-mono","status":"publish","type":"post","link":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/2024\/05\/22\/completablefuture-vs-mono\/","title":{"rendered":"CompletableFuture vs. Mono"},"content":{"rendered":"

<\/p>\n

\"\"<\/p>\n

1. Overview<\/h2>\n
<\/div>\n

In this quick tutorial, we’ll learn the differences between CompletableFuture<\/em> and Mono<\/em> from Project Reactor in Java. We’ll focus on how they handle asynchronous tasks and the execution that occurs to accomplish those tasks.<\/p>\n

Let’s start by looking at CompletableFuture<\/em>.<\/p>\n

2. Understanding CompletableFuture<\/em><\/h2>\n
<\/div>\n

Introduced in Java 8,\u00a0CompletableFuture<\/a><\/em>\u00a0builds upon the previous Future<\/em><\/a> class and provides a way to run code asynchronously. In short, it improves asynchronous programming and simplifies working with threads.<\/p>\n

Moreover, we can create a chain of computations with methods like thenApply()<\/a><\/em>, thenAccept()<\/em><\/a>, and\u00a0thenCompose()<\/a><\/em>\u00a0to coordinate our asynchronous tasks.<\/p>\n

While CompletableFuture<\/em> is asynchronous, meaning the main thread continues executing other tasks without waiting for the completion of the current operation, it isn’t fully non-blocking<\/strong>. A long-running operation can block the thread executing it:<\/p>\n

CompletableFuture completableFuture = CompletableFuture.supplyAsync(() -> {\r\n    try {\r\n        Thread.sleep(1000);\r\n    } catch (InterruptedException e) {\r\n        Thread.currentThread().interrupt();\r\n    }\r\n    return "Finished completableFuture";\r\n});\r\n<\/code><\/pre>\n
Above, we’re simulating a long operation with the sleep()<\/em> method from the Thread<\/em> class. If not defined, supplyAsnc()<\/em> will use ForkJoinPool<\/em> and assign a thread to run the anonymous lambda function<\/a>, and this thread gets blocked by the sleep()<\/em> method.<\/p>\n
Moreover, calling the get()<\/em> method in the CompletableFuture<\/em> instance before it completes the operation blocks the main thread<\/strong>:<\/p>\n
try {\r\n    completableFuture.get(); \/\/ This blocks the main thread\r\n} catch (InterruptedException | ExecutionException e) {\r\n    e.printStackTrace();\r\n}<\/code><\/pre>\n
To avoid such occurrences, we can handle the CompletableFuture<\/em> completion manually using the completeExceptionally()<\/em> or complete()<\/em> methods in the callback pattern<\/a>. For example, suppose we have a function that we want to run without blocking the main thread, and then, we want to handle the future when it fails and when it completes successfully:<\/p>\n
public void myAsyncCall(String param, BiConsumer<String, Throwable> callback) {\r\n    new Thread(() -> {\r\n        try {\r\n            Thread.sleep(1000);\r\n            callback.accept("Response from API with param: " + param, null);\r\n        } catch (InterruptedException e) {\r\n            callback.accept(null, e);\r\n        }\r\n    }).start();\r\n}\r\n<\/code><\/pre>\n
Then, we use this function to create a CompletableFuture<\/em>:<\/p>\n
public CompletableFuture<String> nonBlockingApiCall(String param) {\r\n    CompletableFuture<String> completableFuture = new CompletableFuture<>();\r\n    myAsyncCall(param, (result, error) -> {\r\n        if (error != null) {\r\n            completableFuture.completeExceptionally(error);\r\n        } else {\r\n            completableFuture.complete(result);\r\n        }\r\n    });\r\n    return completableFuture;\r\n}\r\n<\/code><\/pre>\n
There’s an alternative and a more reactive way to handle the same operation, as we’ll see next.<\/p>\n
3. Comparing Mono<\/em> With CompletableFuture<\/em><\/h2>\n
<\/div>\n
The Mono<\/em> class from Project Reactor<\/a>\u00a0uses reactive principles. Unlike CompletableFuture<\/em>, Mono<\/em> is designed to be non-blocking and to support concurrency with less overhead<\/strong>.<\/p>\n
Additionally, Mono<\/em> is lazy compared to the eager execution of the CompletableFuture<\/em>, meaning that our application won’t consume resources unless we subscribe to Mono<\/em>:<\/p>\n
Mono<String> reactiveMono = Mono.fromCallable(() -> {\r\n    Thread.sleep(1000); \/\/ Simulate some computation\r\n    return "Reactive Data";\r\n}).subscribeOn(Schedulers.boundedElastic());\r\nreactiveMono.subscribe(System.out::println);\r\n<\/code><\/pre>\n
Above, we’re creating a Mono<\/em> object using the fromCallable()<\/em> method and providing the blocking operation as a supplier<\/a>. Then, we delegate the operation, using the subscribeOn()<\/em> method, to a separate thread.<\/p>\n
Schedulers.boundedElastic()<\/em>\u00a0is similar to a cached thread pool but with a limit on the maximum number of threads<\/strong>. This ensures the main thread remains non-blocking. The only way to block the main thread is forcefully call the block()<\/em> method. This method waits for the completion, successful or not, of the Mono<\/em> instance.<\/p>\n
Then, to run the reactive pipeline, we use subscribe()<\/em> to subscribe the outcome of the Mono<\/em> object to println()<\/em> using method reference<\/a>.<\/p>\n
The Mono<\/em> class is very flexible and provides a set of operators to transform and combine other Mono<\/em> objects descriptively. It also supports backpressure<\/a> to prevent the application from eating up all the resources.<\/p>\n
4. Conclusion<\/h2>\n
<\/div>\n
In this quick article, we compared CompletableFuture<\/em> with the Mono<\/em> class from Project Reactor. First, we described how CompletableFuture<\/em> can run an asynchronous task. Then, we showed that, if configured incorrectly, it can block the thread it’s working on as well as the main thread. Finally, we showed how to run an asynchronous operation in a reactive way using Mono<\/em>.<\/p>\n
As always, we can find the complete code over on GitHub<\/a>.<\/p>\n
\"\"<\/p>\n
<\/a> <\/a> <\/a> <\/a> <\/a> <\/a> <\/a> <\/div>\n\n
\\\"IT\u96fb\u8166\u88dc\u7fd2
\u7acb\u523b\u8a3b\u518a\u53ca\u5831\u540d\u96fb\u8166\u88dc\u7fd2\u8ab2\u7a0b\u5427!<\/figcaption><\/figure>\r\n<\/br>Find A Teacher Form:\r\n<\/br>https:\/\/docs.google.com\/forms\/d\/1vREBnX5n262umf4wU5U2pyTwvk9O-JrAgblA-wH9GFQ\/viewform?edit_requested=true#responses\r\n<\/br><\/br>Email:\r\n<\/br>public1989two@gmail.com






\r\nwww.itsec.hk<\/a>
\r\nwww.itsec.vip<\/a>
\r\nwww.itseceu.uk<\/a>
<\/p>","protected":false},"excerpt":{"rendered":"
\"\"<\/p>\n
In this quick tutorial, we’ll compare CompletableFuture and Mono from Project Reactor in Java, focusing on how they handle asynchronous tasks.<\/p>\n
<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/a>\u00a0<\/div>\n<\/div>","protected":false},"author":2058,"featured_media":0,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"slim_seo":{"title":"CompletableFuture vs. Mono - ITTeacherITFreelance.hk","description":"In this quick tutorial, we'll compare CompletableFuture and Mono from Project Reactor in Java, focusing on how they handle asynchronous tasks. \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0"},"footnotes":""},"categories":[6,1307],"tags":[10805],"_links":{"self":[{"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/posts\/329573"}],"collection":[{"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/users\/2058"}],"replies":[{"embeddable":true,"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/comments?post=329573"}],"version-history":[{"count":1,"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/posts\/329573\/revisions"}],"predecessor-version":[{"id":329574,"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/posts\/329573\/revisions\/329574"}],"wp:attachment":[{"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/media?parent=329573"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/categories?post=329573"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/itteacheritfreelance.hk\/wordpress\/index.php\/wp-json\/wp\/v2\/tags?post=329573"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}