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 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);
+		}
+	}
+}
+</code>