Discussion :

[onlytoine]

Hello,

Je cherche à faire quelque chose d'assez simple (via l'api java.util.concurrent) : l'idée est de lancer une tache dans un seul thread et de le surveiller afin de le "tuer" si l’exécution de celui-ci dure depuis plus de N millisecondes.

J'ai essayé plusieurs combinaisons avec Executors, CyclicBarrier, etc... Mais je n'arrive pas à faire ce que je veux. A noter que dans mon code de test, je simule le durée du thread à monitorer avec un Thread.sleep().

Merci !
Toine

[thelvin]

Un Thread tout simple peut être arrêté avec un appel à interrupt(), ce qui arrêtera toute action bloquante (comme sleep()) avec un InterruptedException. Cela ne marchera pas si le Thread ne fais jamait d'opération bloquante. Dans ce cas, il doit vérifier de temps en temps avec isInterrupted() s'il ne devrait pas s'arrêter.

À noter que quand on joue avec les Executor, on peut se tourner vers ExecutorService et leurs méthodes invoke() qui renvoient un Future.

On peut attendre la complétion de ce Future pendant un certain temps, avec get(). Et ce temps n'a pas suffi, il est possible d'appeler cancel() sur le Future pour qu'il fasse interrupt() sur le Thread concerné.

[onlytoine]

Merci thelvin,

Dans mon cas, le thread que je souhaite monitorer effectue un appel sur le réseau.

Je voudrais que mon code soit le plus fiable possible :

- j'embarque mon appel réseau dans un thread dédié
- j’exécute ce thread en indiquant que celui-ci ne doit pas durer plus de N secondes
- j'attends la fin de l’exécution (fin normale ou timeout)
- ...

Toine

[GLDavid]

Bonjour

Je me suis posé une question similaire ici: http://www.developpez.net/forums/d12...read-executor/
Je pense également qu'un ScheduledThreadPoolExecutor devrait te convenir.

@++