Πώς βοηθούν το Executor framework και το CompletableFuture στην ασύγχρονη εργασία;

Question

Accepted Answer

Το **Executor framework** διαχειρίζεται κουλούρια threads, οπότε υποβάλλετε *εργασίες* αντί να δημιουργείτε threads χειροκίνητα, και το **`CompletableFuture`** συνθέτει ασύγχρονες λειτουργίες δηλωτικά. Μαζί είναι ο σύγχρονος τρόπος για να κάνετε concurrent/async εργασία στη Java — αποφεύγοντας το κόστος και την πολυπλοκότητα της διαχείρισης surrogates threads. ## Το πρόβλημα με raw threads ```java // ❌ creating a thread per task is expensive and unbounded → can exhaust resources for (Task t : tasks) { new Thread(() -> process(t)).start(); // 10,000 tasks → 10,000 threads → crash } ``` ## ExecutorService — διαχειριζόμενα thread pools ```java // ✅ a fixed pool reuses a bounded set of threads for many tasks ExecutorService executor = Executors.newFixedThreadPool(10); Future future = executor.submit(() -> compute()); // submit a task Integer result = future.get(); // blocks until the result is ready executor.shutdown(); // stop accepting tasks; let running ones finish ``` Ένα `ExecutorService` διαχωρίζει το *τι* (εργασίες) από το *πώς* (διαχείριση threads) — επαναχρησιμοποιεί ένα περιορισμένο κουλούρι threads, αποτρέποντας την εξάντληση πόρων και την υπερβολική δαπάνη της συνεχούς δημιουργίας threads. ## Ο περιορισμός του Future ```java Future f = executor.submit(task); f.get(); // ❌ BLOCKS the calling thread; can't chain/combine without blocking ``` Το `Future.get()` μπλοκάρει, και δεν μπορείτε εύκολα να συνδέσετε εξαρτημένες λειτουργίες ή να συνδυάσετε αποτελέσματα — κάτι που διορθώνει το `CompletableFuture`. ## CompletableFuture — composable async ```java CompletableFuture.supplyAsync(() -> fetchUser(id)) // run async, returns a value .thenApply(user -> user.getName()) // transform the result (non-blocking) .thenApply(String::toUpperCase) .thenAccept(name -> System.out.println(name)) // consume the final result .exceptionally(ex -> { log(ex); return null; }); // handle errors in the chain ``` Το `CompletableFuture` σας επιτρέπει να δημιουργήσετε **non-blocking pipelines** — μετασχηματίζοντας (`thenApply`), συνδέοντας εξαρτημένες async κλήσεις (`thenCompose`), και χειριζόμενο σφάλματα (`exceptionally`) — χωρίς να μπλοκάρετε threads. ## Συνδυασμός πολλαπλών ασύγχρονων λειτουργιών ```java // run two independent async calls in PARALLEL and combine their results CompletableFuture userF = CompletableFuture.supplyAsync(() -> fetchUser(id)); CompletableFuture orderF = CompletableFuture.supplyAsync(() -> fetchOrder(id)); userF.thenCombine(orderF, (user, order) -> buildProfile(user, order)) .thenAccept(profile -> render(profile)); // wait for many to complete CompletableFuture.allOf(f1, f2, f3).join(); // all done ``` Τα `thenCombine`, `allOf`, και `anyOf` συντονίζουν πολλαπλές async εργασίες κομψά — εκτελώντας ανεξάρτητη εργασία σε παράλληλα και συνδυάζοντας αποτελέσματα. ## Γιατί έχει σημασία Το Executor framework και το CompletableFuture είναι ο **σύγχρονος, σωστός τρόπος** να χειρίζεστε concurrency και ασύγχρονη εργασία στη Java, αντικαθιστώντας τη διαχείριση χειροκίνητα threads που είναι επιρρεπής σε σφάλματα. Τα thread pools (ExecutorService) αποφεύγουν την εξάντληση πόρων και την υπερβολική δαπάνη της δημιουργίας ενός thread ανά εργασία — απαραίτητο για scalable servers. Το CompletableFuture επιλύει τον περιορισμό μπλοκαρίσματος του Future ενεργοποιώντας **composable, non-blocking pipelines** που συνδέουν, μετασχηματίζουν, συνδυάζουν, και χειρίζονται σφάλματα ασύγχρονων λειτουργιών δηλωτικά — κρίσιμο για αποδοτικές υπηρεσίες περιορισμένης ταχύτητας I/O που πρέπει να συντονίσουν πολλές concurrent κλήσεις (database, API, microservices). Το να κατανοείτε αυτά (αντί raw threads και blocking Futures) είναι θεμελιώδες για να δημιουργήσετε αποδοτικές, scalable concurrent Java εφαρμογές και είναι μια βασική ικανότητα σε επίπεδο senior.