<code java>
package threadPoolConTerminazione;

public class ComputerThread<T,S> extends Thread {

	Repository<T> tasks = null; 
	Repository<S> results = null; 
	Compute<T,S> function = null; 

	public ComputerThread(Repository<T> tasks, Repository<S> results, Compute<T,S> function) {
		this.tasks = tasks; 
		this.results = results; 
		this.function = function; 
		return;
	}

	public void run() {
		while(true) {
			T task = null; 
			try {
				task = tasks.extract();
			} catch (EndOfStreamException e) {
				System.out.println("Thread "+this.getName()+" ricevuto EoS");
				return; // fine lavori
			} catch (InterruptedException e) {
				System.out.println("Estrazione task interrotta");			
			}
			try {
				int random =  ((int)(Math.random() * 5000.00));
				System.out.println("Thread "+this.getName()+" inizio calcolo");
				sleep(random);
				S result = function.compute(task); 
				System.out.println("Thread "+this.getName()+" fine calcolo");
				results.insert(result);
			} catch(InterruptedException e) { System.out.println("Calcolo del thread "+this.getName()+" interrotto!");}

			System.out.println("Thread "+this.getName()+" computed task "+task);

		}
	}

}
</code>