DidaWiki

package threadPoolConTerminazione;
 
public class Generatore extends Thread {
 
	Repository<Integer> rep = null; 
	int n = 10;
	final int DELAY = 1000;
	final float RANGE = (float) 1024.00;
 
	/**
	 * costruttore
	 * @param n numero di oggetti da generare
	 * @param tasks repository nel quale depositare gli oggetti generati 
	 */
	public Generatore(int n, Repository<Integer> tasks) {
		this.rep = tasks; 
		this.n = n;
	}
 
	/**
	 * corpo del thread generatore: ciclo finito che genera interi compresi fra 0 e RANGE
	 */
	public void run() {
		for(int i=0; i<n; i++) {
			rep.insert(new Integer((int) (Math.random() * RANGE)));
		}
		rep.eos();
	}
 
}