Thread (ou tâche) simplifié

Contenu du snippet

La Classe abstraite "Tache" ci dessous gère proprement une exécution de thread et de façon simplifiée.

Elle exécute sa méthode action() en boucle, peut être lancée, stoppée, et n'est pas, comme le thread, à usage unique.

Elle comprend également une méthode execOnStop() s'exécutant lors de l'arrêt de la tâche.

En fait, il suffit d'implémenter une classe héritant de celle-ci et redéfinissant la méthode action() et eventuellement la méthode execOnStop() pour créer sa propre tâche propre.

Ensuite, la lancer par la méthode start() et l'arrêter par la méthode stop().

Source / Exemple :


/** Classe abstraite contrôlant une tâche simple et "propre" exécutant

  • sa méthode "action()" en boucle, en continu ou avec un délai entre deux exécutions.
  • @author Jonathan Raffin
  • /
public abstract class Tache { /** Etat actif ou non. */ private boolean actif; /** Délai en millisecondes entre deux exécutions. */ private long delai_ms; /** Délai additif en nanosecondes. */ private int add_ns; /** Tâche exécutant le code. */ private Thread thread; /** Constructeur. */ public Tache() { actif = false; thread = null; delai_ms = 0; add_ns = 0; } /** Constructeur incluant un délai en millisecondes. */ public Tache(long delai) { actif = false; thread = null; delai_ms = delai; add_ns = 0; } /** Constructeur incluant un délai en millisecondes, ajouté d'une valeur en nanosecondes. */ public Tache(long delai, int nanos) { actif = false; thread = null; delai_ms = delai; add_ns = nanos; } /** Méthode redéfinissant le délai.
  • @param delai Délai en millisecondes.
  • /
public void setDelai(long delai) { if(delai>0) delai_ms = delai; else delai_ms = 0; } /** Méthode redéfinissant le délai.
  • @param delai Délai en millisecondes.
  • @param nanos Délai additionnel en nanosecondes.
  • /
public void setDelai(long delai, int nanos) { if(delai>0) { delai_ms = delai; if(nanos>0) add_ns = nanos; else add_ns = 0; } else delai_ms = 0; } /** Méthode appellée en boucle par la tâche. */ protected abstract void action() throws Exception; /** Démarre la tâche si elle n'est pas déjà démarrée. */ synchronized public void start() { if(thread==null) { thread = new Thread() { // Création d'une nouvelle tâche bouclant sur action(). /** Booléen définissant si le thread doit boucler ou s'arrêter. */ private boolean act = true; /** Action principale du thread. */ public void run() { while(act) { try { action(); if((delai_ms)>0) { // Gestion du délai. try { if(add_ns>0) sleep(delai_ms, add_ns); else sleep(delai_ms); } catch (InterruptedException e) { arret(); } } } catch (Exception e) { System.err.print("Exception rencontrée dans le thread ["+thread.getName()+"]: "); e.printStackTrace(System.err); arret(); } // Si l'attribut de l'objet de classeMaTache // est à faux, arrêt définitif de la boucle. if(actif==false) act = false; } } }; actif = true; thread.start(); // Lance la tâche. } } /** Méthode permettant au thread de demander son propre arrêt. */ private void arret() { delai_ms = 0; stop(); } /** Stoppe l'exécution de la tâche après la fin de la méthode "action()" */ synchronized public void stop() { if(thread!=null) { actif = false; if(delai_ms>0) thread.interrupt(); thread = null; } } }

Conclusion :


Attention, les méthodes start() et stop() ne sont en aucun cas des méthode redéfinies de la classe Thread, tout comme la classe Tache n'est pas une classe héritant de la classe Thread.

Voilà, en espérant avoir été utile...

Cette classe est également sensée gérer toute exception aparaissant dans action().

Prévenez moi pour tout bugs ou autres...

Riven

A voir également

Vous n'êtes pas encore membre ?

inscrivez-vous, c'est gratuit et ça prend moins d'une minute !

Les membres obtiennent plus de réponses que les utilisateurs anonymes.

Le fait d'être membre vous permet d'avoir un suivi détaillé de vos demandes et codes sources.

Le fait d'être membre vous permet d'avoir des options supplémentaires.