Warum wirft Executors.newCachedThreadPool java.util.concurrent.RejectedExecutionException beim Senden aus

Question

Die Anzahl der eingereichten Aufgaben (Threads) ist in diesem Testszenario ebenfalls nicht groß.

Answer 1

Sie werden Code-Beispiele, wie Sie instanziiert zur Verfügung stellen müssen und submit auf den Pool nennen (IP hier kein Thema sein sollte, da wir wie der Interna Ihrer Callable Klassen oder irgendetwas nicht Details brauchen Das).

Basierend auf den Informationen, die Sie angegeben haben, schließen Sie den Executor-Service mit ziemlicher Sicherheit, bevor Sie ihn absetzen. Überprüfen Sie, ob Sie Anrufe an shutdown oder shutdownNow tätigen, und wenn ja, stellen Sie sicher, dass Sie nach diesem Punkt keine Aufgaben hinzufügen.

Darüber hinaus möchten Sie vielleicht Ihre eigene Implementierung von java.util.concurrent.RejectedExecutionHandler registrieren, um beim Debuggen zu helfen; Seine Nachricht rejectedExecution wird immer dann aufgerufen, wenn der Executor eine Aufgabe nicht annehmen kann. Sie können also eine rudimentäre State-Inspection-Logik verwenden, um die Ursache zu finden.

Answer 2

Ich sehe nirgendwo im Aufruf der Executors.newCachedThreadPool() Methoden, wo ein RejectedExecutionException geworfen wird. Es gibt nur drei Fälle, in denen es in Java 6 geworfen zu sein scheint:

• wenn execute() auf einem ThreadPoolExecutor und die maximale Poolgröße Aufruf erreicht wurde.
• beim Aufruf execute() auf einer ThreadPoolExecutor zur gleichen Zeit, die shutdownNow, und hat im Wesentlichen das Rennen mit dem shutdownNow Anruf verloren.
• bei dem Versuch, die Ausführung eines Runnable in einem ScheduledThreadPoolExecutor nach dem Herunterfahren des Executor geplant zu planen.