Java ExecutorService ordnungsgemäß herunterfahren

Executoren sind eine bequeme Möglichkeit, Aufgaben gleichzeitig in Java-Anwendungen zu verwalten und auszuführen. Ein unsachgemäßes Herunterfahren kann jedoch zu unerwartetem Verhalten oder Leistungsproblemen führen. In diesem Handbuch wird ausführlich erklärt, wie ein ExecutorService ordnungsgemäß heruntergefahren wird, um sicherzustellen, dass alle Aufgaben beendet oder abgebrochen werden.

Grundlegendes zum Herunterfahren von ExecutorService

ExecutorService bietet zwei primäre Methoden zum Herunterfahren :

• shutdown(): Verhindert, dass neue Aufgaben übermittelt werden, während dies zugelassen wird Vorhandene Aufgaben müssen abgeschlossen werden.
• shutdownNow(): Versucht, alle ausgeführten und wartenden Aufgaben zu stoppen und gibt eine Liste unverarbeiteter Aufgaben zurück.

Das ist wichtig zu beachten Es ist nicht garantiert, dass beim Herunterfahren alle Aufgaben beendet werden. Aufgaben, die nicht auf Interrupts reagieren oder lange laufende Vorgänge haben, bleiben möglicherweise aktiv.

Empfohlenes Herunterfahrenverfahren

Die Oracle-Dokumentation schlägt den folgenden Ansatz für ein ordnungsgemäßes Herunterfahren vor:

void shutdownAndAwaitTermination(ExecutorService pool) {
    pool.shutdown();
    try {
        // Wait for existing tasks to terminate
        if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
            pool.shutdownNow();
            // Wait for tasks to respond to cancellation
            if (!pool.awaitTermination(60, TimeUnit.SECONDS))
                System.err.println("Pool did not terminate");
        }
    } catch (InterruptedException ie) {
        pool.shutdownNow();
        Thread.currentThread().interrupt();
    }
}

Dieser Ansatz stellt sicher, dass vorhandene Aufgaben abgeschlossen werden können, während neue Übermittlungen verhindert werden. Wenn der Herunterfahrvorgang länger dauert als erwartet, können Sie

if (!pool.awaitTermination(60, TimeUnit.SECONDS))

durch

while (!pool.awaitTermination(60, TimeUnit.SECONDS))

um weiter auf die Aufgabe zu warten Abschluss.

Zusammenfassung der Methoden zum Herunterfahren

• shutdown(): Stoppt die Annahme neuer Aufgaben, ermöglicht aber den Abschluss vorhandener Aufgaben.
• shutdownNow(): Stoppt alle ausgeführten und wartenden Aufgaben und kehrt unverarbeitet zurück Aufgaben.
• awaitTermination(long timeout, TimeUnit-Einheit): Blockiert, bis alle Aufgaben abgeschlossen sind, das Timeout auftritt oder der aktuelle Thread unterbrochen wird.