package threadPool; import java.util.LinkedList; /** * classe che implementa il repository delle cose da calcolare * @author marcod */ public class Repository { private LinkedList ll = null; public Repository() { super(); ll = new LinkedList(); } /** * inserzione di un elemento nel pool * @param data il dato da inserire */ public synchronized void insert(T data) { ll.add(data); notify(); } /** * estrazione dell'elemento più vecchio dal pool * @return il dato più vecchio nel pool (rimosso) */ public synchronized T extract() { while(ll.isEmpty()) { try { wait(); } catch(InterruptedException e) { System.out.println("wait interrotta"); } } return ll.remove(); } }