Comment puis-je implémenter une interruption de tâche chronométrée dans un Java ExecutorService ?

Interruption de tâches dans un ExecutorService avec des délais d'attente

La mise en œuvre d'un ExecutorService personnalisé qui gère les interruptions de tâches après un délai d'attente peut être difficile. Cependant, le cadre de concurrence Java fournit une solution pratique en utilisant le ScheduledExecutorService.

ScheduledExecutorService pour les délais d'attente des tâches

Un ScheduledExecutorService permet de planifier l'exécution de tâches après un délai spécifié ou à intervalles réguliers. intervalles. En tirant parti de cette fonctionnalité, vous pouvez créer un ExecutorService personnalisé qui surveille les tâches soumises et les interrompt si elles dépassent un délai d'attente prédéfini.

Implémentation de TimeoutThreadPoolExecutor

Une approche pour créer un tel un ExecutorService est la classe TimeoutThreadPoolExecutor, qui étend le ThreadPoolExecutor standard. Il intègre un ScheduledExecutorService (timeoutExecutor) et une map concurrente (runningTasks) pour suivre les tâches en cours d'exécution et planifier leurs interruptions.

Fonctionnement de TimeoutThreadPoolExecutor

• beforeExecute : lorsqu'une tâche est soumise, son interruption est planifiée à l'aide de timeoutExécuteur. Un ScheduledFuture est renvoyé et stocké dans runningTasks, mappant la tâche à sa tâche d'interruption planifiée.
• afterExecute : une fois la tâche terminée, son ScheduledFuture correspondant est supprimé de runningTasks et annulé, interrompant la tâche. s'il n'est pas déjà terminé.
• arrêt : Gracieusement arrête à la fois ThreadPoolExecutor et ScheduledExecutorService.
• shutdownNow : arrête de force ThreadPoolExecutor et ScheduledExecutorService.

Utilisation

Pour utiliser cet ExecutorService personnalisé, instanciez un TimeoutThreadPoolExecutor avec les paramètres souhaités et commencez à soumettre des tâches. Les tâches seront interrompues après le délai d'attente spécifié si elles ne sont pas terminées.

Méthode alternative utilisant la planification

Une autre approche pour interrompre les tâches de longue durée dans un ExecutorService est pour utiliser la méthode de planification fournie par ScheduledExecutorService. Vous pouvez soumettre deux tâches : une qui exécute la tâche réelle et une autre qui l'annule après un délai d'attente spécifié.

Exemple de code

ScheduledExecutorService executor = Executors.newScheduledThreadPool(2); 
Future handler = executor.submit(new Callable(){ ... });
executor.schedule(new Runnable(){
    public void run(){
        handler.cancel();
    }      
}, 10000, TimeUnit.MILLISECONDS);

Cette méthode vous permet de exécuter une tâche avec un délai d'attente de 10 secondes, après quoi elle sera annulée et interrompue.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!