<code java>
package threadPoolConcurrencyDue;

import java.util.concurrent.*;
public class Stampatore<T> extends Thread {

	
	LinkedBlockingQueue<T> rep;
	
	public Stampatore(LinkedBlockingQueue<T> results) {
		this.rep = results; 
	}
	
	public void run() {
		while(true) {
			T i;
			try {
				i = rep.take();
				System.out.println("Estratto "+i.toString());
			}  catch (InterruptedException e) {
				// fine lavori 
				return;
			}
			
		}
	}
}
</code>