no way to compare when less than two revisions

Differenze

Queste sono le differenze tra la revisione selezionata e la versione attuale della pagina.

@@ Linea 1: / Linea 1: @@
+<code java>
+package threadPoolConcurrencyDue;
+import java.util.concurrent.*;
+public class ProvaThreadPool {
+	public static void main(String[] args) {
+		final int N = 16;		// numero dei task da calcolare
+		final int T = 4;		// numero minimo di thread nel pool
+		final int MAX_T = 8;    // numero massimo di thread nel pool
+		ThreadPoolExecutor tpe = null; 		// creazione dell'esecutore
+		tpe = new ThreadPoolExecutor(T,MAX_T,10000L,TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
+		// creazione del repository per i risultati
+		LinkedBlockingQueue<Integer> results = new LinkedBlockingQueue<Integer>();
+		// creazione del thread stampatore
+		Stampatore<Integer> stampatore = new Stampatore<Integer>(results);
+		stampatore.start();
+		// funzione da calcolare
+		Compute<Integer,Integer> fun = new FunzioneSemplice();
+		// questo sostituisce il codice del generatore:
+		for(int i=0; i<N; i++) {                 // per ogni task,
+			Task t = new Task(i,fun,results);	 // crea un nuovo Task Runnable
+			tpe.execute(t);						 // e lo passa al ThreadPoolExceutor
+			try {Thread.sleep(10); } catch(InterruptedException e) {e.printStackTrace();}  // attende un po' prima di generarne un altro
+		}
+		tpe.shutdown();		// equivalente alla dichiarazione di fine stream del generatore
+		try {
+			tpe.awaitTermination(50000L, TimeUnit.MILLISECONDS);   // attesa della terminazione
+		} catch (InterruptedException e) {
+			System.out.println("ThreadPoolExecutor non ha terminato l'esecuzione: scatta timeout");
+		}
+		System.out.println("Tutti i thread del pool sono terminati\nTerminazione Stampatore ...");
+		stampatore.interrupt();	// come prima
+		System.out.println("Terminazione main");
+		// fine lavori ...
+		return;
+	}
+}
+</code>