Executor okvir upravlja bazene niti, tako da oddajaš naloge namesto ročnega ustvarjanja niti, CompletableFuture pa sestavi asinkrone operacije deklarativno. Skupaj sta moderni način za konkurenčni/asinkroni posel v Javi — izogibanje strošku in kompleksnosti ročnega upravljanja niti.
(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 ločuje kaj (naloge) od kako (upravljanje niti) — ponovno uporablja omejen bazen niti, preprečuje izčrpavanje virov in stroške nenehnega ustvarjanja niti.
Future<Integer> f = executor.submit(task);
f.get(); // ❌ BLOCKS the calling thread; can't chain/combine without blocking
Future.get() blokira in ne moreš enostavno povezati odvisnih operacij ali kombinirati rezultatov — kar je tisto, kar CompletableFuture popravlja.
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 ti omogoči gradnjo ne-blokirajočih cevovodov — transformacija (thenApply), povezava odvisnih asinkrnih klicev (thenCompose) in obravnavanje napak (exceptionally) — brez blokiranja niti.
// 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 in anyOf koordinirajo več asinkrnih nalog elegantno — независно opravljajo delo vzporedno in kombinirajo rezultate.
Executor okvir in CompletableFuture sta moderni, pravilen način za obravnavanje konkurenčnosti in asinkronega dela v Javi, zamenjujeta ranljivo ročno upravljanje niti.
Bazeni niti (ExecutorService) se izognejo izčrpanju virov in stroškom ustvarjanja niti za vsako nalogo — bistveno za razširljive strežnike.
CompletableFuture rešuje Future-jevo blokirajočo omejitev z omogočanjem sestavljivih, ne-blokirajočih cevovodov, ki verižijo, transformirajo, kombinirajo in z napaka-obravnavajo asinkrone operacije deklarativno — ključno za učinkovite vhodno-izhodne storitve, ki morajo koordinirati veliko sočasnih klicev (podatkovna baza, API, mikroservisi).
Razumevanje teh (preko surovih niti in blokirajočih Future) je temeljno za gradnjo zmogljivih, razširljivih konkurenčnih Java aplikacij in je ključna kompetentnost višje ravni.