DidaWiki

Questa pagina è in sola lettura. Puoi visualizzare il sorgente, ma non puoi modificarlo. Contatta l'amministratore se pensi che ci sia un errore.

<code java>
package threadPoolConTerminazione;


public class ProvaThreadPool {

	public static void main(String[] args) {

		final int N = 8;
		final int T = 4; 
		
		Repository<Integer> tasks = new Repository<Integer>();
		Repository<Integer> results = new Repository<Integer>();
		FunzioneSemplice funz = new FunzioneSemplice();
		ComputerThread[] ct = new ComputerThread[T];
		
		Generatore generatore = new Generatore(N,tasks);
		Stampatore<Integer> stampatore = new Stampatore<Integer>(results);
		generatore.start();
		stampatore.start();
		
		System.out.println("Creazione dei thread nel pool ");
		for(int i=0; i<T; i++) {
			ct[i] = new ComputerThread<Integer,Integer>(tasks, results, funz);
			ct[i].start();
		}
		System.out.println("Attesa terminazione thread del pool ...");
		for(int i=0; i<T; i++) {
			try {
				ct[i].join();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("Tutti i thread del pool sono terminati\nTerminazione Stampatore ...");
		stampatore.interrupt();
		System.out.println("Terminazione main");
		return;		
	}

}
</code>