Executor-kehys hallinnoi säikeiden pooleja niin, että voit lähettää tehtäviä sen sijaan, että luoisit säikeitä manuaalisesti, ja CompletableFuture koostaa asynkronisia operaatioita deklaratiivisesti. Yhdessä ne ovat nykyaikainen tapa tehdä samanaikaista/asynkronista työtä Javassa — välttäen raakojen säikeiden hallinnan kustannukset ja monimutkaisuuden.
(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 erottaa mitä (tehtävät) kuinka-osasta (säikeiden hallinta) — se käyttää rajoitetun kokoisen säikeiden poolia uudelleen, mikä estää resurssien loppumisen ja säikeiden jatkuvan luomisen yleiskustannukset.
Future-rajapinnallaFuture<Integer> f = executor.submit(task);
f.get(); // ❌ BLOCKS the calling thread; can't chain/combine without blocking
Future.get() estää suoritusta, etkä voi helposti ketjuttaa riippuvaisia operaatioita tai yhdistää tuloksia — mitä CompletableFuture korjaa.
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 antaa sinulle mahdollisuuden rakentaa ei-estäviä putkilinjoja — muuntaa (thenApply), ketjuttaa riippuvaisia asynkronisia kutsuja (thenCompose) ja käsitellä virheitä (exceptionally) — ilman säikeiden estämistä.
// 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 ja anyOf koordinoivat useita asynkronisia tehtäviä tyylikkäästi — ajamalla itsenäisen työn rinnakkain ja yhdistämällä tulokset.
Executor-kehys ja CompletableFuture ovat nykyaikainen, oikea tapa käsitellä samanaikaisuutta ja asynkronista työtä Javassa, korvaten virheille alttiiden manuaalisten säikeiden hallinnan.
Säikeiden poolit (ExecutorService) välttävät resurssien loppumisen ja yhden säikeen luomisen yleiskustannukset per tehtävä — välttämätön skaalautuville palvelimille.
CompletableFuture ratkaisee Future-rajapinnan estävän rajoituksen mahdollistamalla koostettavat, ei-estävät putkilinjat, jotka ketjuttavat, muuntavat, yhdistävät ja käsittelevät virheitä asynkronisissa operaatioissa deklaratiivisesti — kriittinen tehokkaasti toimiville I/O-rajapinnassa olevaisille palveluille, joiden on koordinoitava monia samanaikaisia kutsuja (tietokanta, API, mikropalvelut).
Näiden ymmärtäminen (raakojen säikeiden ja estävien Future-rajapintojen sijaan) on perustavanlaatuista suorituskykykkäiden, skaalautuvien samanaikaisten Java-sovellusten rakentamiselle ja on keskeinen senior-tason osaaminen.