Utiliser un démon

Il existe deux sortes de threads :

• les threads utilisateurs : un thread utilisateur se termine lorsque sa méthode run s'est achevée (ou lorsqu'elle a été arrêtée par sa méthode stop, qui est dépréciée) ; l'application se termine quand tous les threads utilisateurs se sont terminés ;
• les threads démons : un thread démon se termine si sa méthode run s'est achevée (ou lorsqu'elle a été arrêtée par sa méthode stop) mais aussi quand tous les threads utilisateurs se sont terminés.

Le programme qui nous sert ici d'exemple doit utiliser un thread démon, le collecteur de mots, pour collecter dans une chaîne de caractères des mots produits par un ensemble de producteurs de mots, qui sont des threads utilisateurs.

Le collecteur de mots dispose d'un attribut mot (de type String) pouvant contenir un mot et un second attribut (de type StringBuilder) lui servant à collecter les mots.

Dans sa méthode run, un producteur répète trois fois les opérations suivantes :

• il attend éventuellement que le collecteur « ne soit plus occupé » ;
• il dépose son mot chez le collecteur, grâce à l'attribut mot de celui-ci ;
• il effectue une notification (grâce à la méthode notify) afin de prévenir le collecteur qu'il a déposé un mot.

import java.util.Random;

class Generateur {
	static Random alea = new Random();
}

class Collecteur extends Thread {
	private StringBuilder texte = new StringBuilder();
	private boolean travailAFaire = false;
	private String mot;

	Collecteur() {
		setDaemon(true);
	}

	public String getMot() {
		return mot;
	}

	public void setMot(String mot) {
		this.mot = mot;
	}
	
	public boolean isTravailAFaire() {
		return travailAFaire;
	}

	public void setTravailAFaire(boolean travailAFaire) {
		this.travailAFaire = travailAFaire;
	}

	public synchronized void run() {
		try {
			while(true) {
				while(!travailAFaire) wait();
				texte.append(mot);
				System.out.println(texte);
				travailAFaire = false;
				notifyAll();
			}
		}
		catch(InterruptedException e) {}
	}
}

class ProducteurMots extends Thread {
	private Collecteur collecteur;
	private String mot;

	ProducteurMots(Collecteur collecteur, String mot) {
		this.collecteur = collecteur;
		this.mot = mot;
	}

	public void run() {
		try {
			for (int i = 0; i < 3; i++) {
				sleep(Math.abs(Generateur.alea.nextInt()) % 10);
				synchronized(collecteur) {
					while (collecteur.isTravailAFaire()) collecteur.wait();
					collecteur.setMot(mot);
					collecteur.setTravailAFaire(true);
					collecteur.notifyAll();
				}
			}

		// Ce qui suit evite que le programme ne se termine 
		// avant que le demon n'ait ecrit sa derniere ligne
			synchronized(collecteur) {
				while(collecteur.isTravailAFaire()) collecteur.wait();
			}
		}
		catch(InterruptedException e) {
			e.printStackTrace();}
	}
}

class Assemble {
	public static void main(String[] arg) {
		Collecteur collecteur = new Collecteur();

		collecteur.start();
		new ProducteurMots(collecteur, "soleil ").start();
		new ProducteurMots(collecteur, "lune ").start();
	}
}

soleil 
soleil lune 
soleil lune soleil 
soleil lune soleil soleil 
soleil lune soleil soleil lune 
soleil lune soleil soleil lune lune