THREAD (OU TÂCHE) SIMPLIFIÉ

/** 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;
		}
	}
}

29 novembre 2004 17:44:29 :

Juste une correction du code...