Java v25: выбор подходящей многопоточности для любых задач

Примеры кода

ForkJoinPool для CPU-heavy задачи

ForkJoinPool pool = new ForkJoinPool(24);
long result = pool.submit(() -> 
    LongStream.range(0, 1_000_000_000)
              .parallel()
              .map(i -> i * i)
              .sum()
).get();

CompletableFuture с FixedThreadPool

ExecutorService pool = Executors.newFixedThreadPool(100);
List<CompletableFuture<Void>> futures = new ArrayList<>();
for (int i = 0; i < 1000; i++) {
    futures.add(CompletableFuture.runAsync(() -> doIoTask(), pool));
}
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();

Virtual Threads (Loom) для I/O-heavy задач

ExecutorService loomExecutor = Executors.newVirtualThreadPerTaskExecutor();
for (int i = 0; i < 1_000_000; i++) {
    loomExecutor.submit(() -> doIoTask());
}
loomExecutor.shutdown();