`ExecutorService.close` în Java

Executori și rezultate viitoare (ExecutorService, Future, CompletableFuture) Java 19

Oprește executorul și așteaptă să se termine toate sarcinile; permite folosirea executorului în try-with-resources.

Sintaxă

default void close()

try (ExecutorService executor = Executors.newFixedThreadPool(4)) {
    // trimiți sarcini
} // aici close() așteaptă toate sarcinile

Ce face `ExecutorService.close`

Din Java 19, ExecutorService extinde AutoCloseable. Metoda close() face trei lucruri: apelează shutdown(), așteaptă până se termină toate sarcinile trimise și abia apoi revine.

Asta înseamnă că poți scrie executorul într-un bloc try (...) { }. La ieșirea din bloc, toate sarcinile sunt terminate, chiar dacă în bloc a apărut o excepție. Nu mai ai nevoie de perechea shutdown() + awaitTermination().

Dacă firul care așteaptă în close() este întrerupt, executorul apelează shutdownNow() și încearcă să oprească sarcinile.

Ce returnează

Nimic (void). Când revine, toate sarcinile s-au terminat.

Exemple

Exemplul 1: Executor în try-with-resources

După blocul try, toate cele patru sarcini s-au terminat, deci totalul este complet.

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;

public class Main {
    public static void main(String[] args) {
        int[] vanzari = {120, 340, 75, 260};
        AtomicInteger total = new AtomicInteger();
        try (ExecutorService executor = Executors.newFixedThreadPool(2)) {
            for (int v : vanzari) {
                executor.submit(() -> total.addAndGet(v));
            }
        }
        System.out.println("Total vânzări: " + total.get() + " lei");
    }
}

Rezultat

Total vânzări: 795 lei

Exemplul 2: close() așteaptă și sarcinile lente

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static void main(String[] args) {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        try (executor) {
            executor.submit(() -> {
                Thread.sleep(300);
                System.out.println("Copia de siguranță s-a terminat");
                return null;
            });
            System.out.println("Sarcina a fost trimisă");
        }
        System.out.println("Executor închis: " + executor.isTerminated());
    }
}