Wie funktionieren Executor in Java?

Executor — ist eine Schnittstelle in Java, die einen Vertrag für die Ausführung von Aufgaben in einem Thread-Pool definiert. Anstatt explizit Threads für jede Aufgabe zu erstellen, übergeben Sie die Aufgaben an die Executor-Instanzen, die die Erstellung, Nutzung und Zerstörung der Threads verwalten.

Hauptvorteile:

• Thread-Management: Bietet eine einheitliche Methode zur Verwaltung des Thread-Pools, wodurch manuelles Erstellen und Synchronisieren von Threads vermieden wird.
• Effizienz: Recycelt bestehende Threads, reduziert die Kosten für das Erstellen und Zerstören von Threads.
• Leistung: Verbessert die Leistung und Reaktionsfähigkeit von Anwendungen durch asynchrone Ausführung von Aufgaben.

Executor hat eine Methode:

// Führt den gegebenen Befehl zu einem späteren Zeitpunkt aus.
void execute(Runnable command);

Häufig verwendete Untertypen:

• ExecutorService: Erweitert Executor und bietet zusätzliche Methoden zur Verwaltung des Lebenszyklus des Executors und zum Abrufen von Ergebnissen (z.B. via Future).
• ScheduledExecutorService: Erweitert ExecutorService und ermöglicht die Ausführung von Aufgaben mit Verzögerung oder nach Zeitplan.

Die Klasse Executors stellt Fabrikmethoden bereit, um verschiedene Arten von Executor-Diensten zu erstellen:

// Erstellt einen Thread-Pool mit fester Thread-Anzahl.
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);

// Erstellt einen Thread-Pool, der die Anzahl der Threads dynamisch anpassen kann.
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// Erstellt einen Thread-Pool, der Aufgaben nach Zeitplan ausführen kann.
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

Beispiel für die Verwendung:

// Executor-Objekt
ExecutorService executor = Executors.newFixedThreadPool(2);

// Aufgabe zur Ausführung
Runnable task = new Runnable() {
    @Override
    public void run() {
        // Aufgaben-Code
        System.out.println("Aufgabe wird im Thread ausgeführt: " + Thread.currentThread().getName());
    }
};

// Aufgabe an den Executor übergeben
executor.execute(task);

// Beenden des Executors (erforderlich, um Ressourcen freizugeben)
executor.shutdown();

Beim Aufruf von execute() übernimmt der Executor die Aufgabe (Runnable) und weist sie einem seiner Threads zur Ausführung zu. Die Verwaltung der Aufgabenverteilung und des Lebenszyklus der Threads übernimmt der Executor.