lpr-b:stampatoretpconcurdue
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; } } } }
lpr-b/stampatoretpconcurdue.txt · Ultima modifica: 22/10/2007 alle 14:41 (18 anni fa) da Marco Danelutto