Pourquoi Executors.newCachedThreadPool lance java.util.concurrent.RejectedExecutionException pendant l'envoi

Question

Le nombre de tâches (threads) soumises n'est également pas énorme dans ce scénario de test.

Answer 1

Vous devrez fournir des exemples de code de la façon dont vous instancier et appeler submit sur la piscine (IP devrait être un non-question ici que nous ne avons pas besoin de détails sur le fonctionnement interne de vos Callable classes ou quoi que ce soit comme cette). D'après les informations que vous avez fournies, vous fermez le service d'exécution quelque part avant de soumettre l'appel. Vérifiez si vous faites des appels au shutdown ou au shutdownNow, et si c'est le cas, assurez-vous de ne pas ajouter de tâches après ce point. Au-delà de cela, vous pouvez enregistrer votre propre implémentation de java.util.concurrent.RejectedExecutionHandler afin de faciliter le débogage; son message rejectedExecution sera appelé chaque fois que l'exécuteur est incapable d'accepter une tâche, de sorte que vous pouvez y mettre une logique d'inspection d'état rudimentaire pour vous aider à trouver la cause.

Answer 2

Je ne vois nulle part dans l'appel des méthodes Executors.newCachedThreadPool() où un RejectedExecutionException est levé. Il n'y a que trois cas où il semble être jeté en Java 6:

• lorsque vous appelez execute() sur un ThreadPoolExecutor et la taille de la piscine maximale a été atteinte.
• lors de l'appel execute() sur un ThreadPoolExecutor en même temps que shutdownNow, et a essentiellement perdu la course avec l'appel shutdownNow.
• lors de la tentative de planification de l'exécution d'une exécution dans un ScheduledThreadPoolExecutor après l'arrêt de l'exécuteur.