So stellen Sie sicher, dass die Aufgabe beim Herunterfahren des Java ExecutorService beendet wird

Java ExecutorService Shutdown: Sicherstellung der Task-Beendigung

Beim Umgang mit Java ExecutorService ist ein entscheidender Aspekt die Handhabung des Shutdown-Prozesses, um sicherzustellen, dass alle Tasks ordnungsgemäß beendet werden. Dies wird zu einer Herausforderung, wenn während der Aufgabenausführung Zeitüberschreitungen oder andere Unterbrechungen auftreten.

Benutzerdefinierter Ansatz

Der bereitgestellte Code zeigt ein Szenario, in dem ein ExecutorService, der CallableTask-Objekte ausführt, auf Schwierigkeiten stößt Herunterfahren, nachdem alle Aufgaben abgeschlossen sind. Dieses Problem ergibt sich aus der Möglichkeit, dass Aufgabenthreads, die den Timeout-Schwellenwert überschreiten, aktiv bleiben und so die Beendigung der Ausführung verhindern.

Empfohlene Lösung

Um dieses Problem zu beheben, wird die Oracle-API verwendet Die Dokumentation für ExecutorService empfiehlt den folgenden Ansatz:

<code class="java">void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); 
   try {
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); 
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     pool.shutdownNow(); 
     Thread.currentThread().interrupt();
   }
}</code>

Diese Methode stellt einen ordnungsgemäßen Herunterfahrvorgang sicher:

• shutdown(): Deaktiviert die Übermittlung neuer Aufgaben.
• awaitTermination(): Wartet auf den Timeout-Zeitraum für den Abschluss bestehender Aufgaben.
• shutdownNow(): Unterbricht die Ausführung von Aufgaben, wennawaitTermination() fehlschlägt, und beendet sie zwangsweise.

Kurze Zusammenfassung der Methoden zum Herunterfahren

• shutdown(): Initiiert ein ordnungsgemäßes Herunterfahren, bei dem übermittelte Aufgaben ausgeführt, neue Aufgaben jedoch abgelehnt werden.
• shutdownNow(): Versucht, alle aktiven Aufgaben anzuhalten, ausstehende Aufgaben zu stoppen und eine Liste nicht abgeschlossener Aufgaben zurückzugeben.
• awaitTermination(): Blockiert, bis alle Aufgaben abgeschlossen sind (sei es durch Abschluss oder Unterbrechung).

Zusätzliche Tipps

Um die Zeitüberschreitung beim Herunterfahren für hartnäckige Aufgaben zu verlängern, ändern Sie waitingTermination():

<code class="java">if (!pool.awaitTermination(60, TimeUnit.SECONDS)) </code>

in:

<code class="java">while (!pool.awaitTermination(60, TimeUnit.SECONDS)) </code>

Durch die Implementierung dieser Techniken können Sie die Zuverlässigkeit Ihres ExecutorService-Herunterfahrprozesses verbessern und so eine ordnungsgemäße Aufgabenbeendigung und Systembereinigung sicherstellen.

Das obige ist der detaillierte Inhalt vonSo stellen Sie sicher, dass die Aufgabe beim Herunterfahren des Java ExecutorService beendet wird. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!