Το Executor framework διαχειρίζεται κουλούρια threads, οπότε υποβάλλετε εργασίες αντί να δημιουργείτε threads χειροκίνητα, και το CompletableFuture συνθέτει ασύγχρονες λειτουργίες δηλωτικά. Μαζί είναι ο σύγχρονος τρόπος για να κάνετε concurrent/async εργασία στη Java — αποφεύγοντας το κόστος και την πολυπλοκότητα της διαχείρισης surrogates threads.
(Task t : tasks) {
(() -> process(t)).start();
}
// ✅ a fixed pool reuses a bounded set of threads for many tasks
ExecutorService executor = Executors.newFixedThreadPool(10);
Future<Integer> 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<Integer> f = executor.submit(task);
f.get(); // ❌ BLOCKS the calling thread; can't chain/combine without blocking
Το Future.get() μπλοκάρει, και δεν μπορείτε εύκολα να συνδέσετε εξαρτημένες λειτουργίες ή να συνδυάσετε αποτελέσματα — κάτι που διορθώνει το CompletableFuture.
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.
// run two independent async calls in PARALLEL and combine their results
CompletableFuture<User> userF = CompletableFuture.supplyAsync(() -> fetchUser(id));
CompletableFuture<Order> 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.
Μια βιβλιοθήκη ερωτήσεων συνέντευξης IT με αναλυτικές απαντήσεις — από Junior έως Senior.
Δωρεά