lpr-b-2007-2008:threadcomputecalcolatore
package threadPool; 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 = tasks.extract(); 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); } } }
lpr-b-2007-2008/threadcomputecalcolatore.txt · Ultima modifica: 19/09/2008 alle 14:08 (16 anni fa) da 127.0.0.1