[Java] Problema Produttore-Consumatore con Timer

[antig]

Ho il classico problema Produttore-Consumatore con Buffer con una variante;
Dovrei modificare la classe Buffer che riporto:
public class Buffer<T>{
int n;
T[] buffer;
int in=0,out=0,count=0;
public Buffer(int n){
this.n=n;buffer=new T[n];
}
public synchronized T get(){
while(count==0)
try{wait();}catch(InterruptedException e){}
T risp=buffer[out];out=(out+1)%n;count--;
notifyAll();
return risp;
}
public synchronized void put(T value){
while(count==n)
try{wait();}catch(InterruptedException e){}
buffer[in]=value;in=(in+1)%n;count++;
notifyAll();
}
}

La modifica da apportare utilizzando Timer e TimerTask è questa:
la get deve essere così:
public T get(long timeout) throws TimeoutException
Se la get riceve l'oggetto dal buffer entro il timeout OK altrimenti termina in modo anomalo
lanciando l'eccezione istanza di TimeoutException.

Qualcuno sà come si fà ?

[LeleFT]

Non mi sembra così difficile da fare... dov'è la difficoltà nell'implementare tale metodo?


Ciao.

[antig]

Lo so che non è complicato ...
solo che io non so come si fà!

[LeleFT]

Vediamo, quindi, di abbozzare un'idea.
L'idea è quella di prendere il tempo all'entrata del metodo. Quindi controllare se ci sono degli oggetti disponibili. Se non ci sono degli oggetti disponibili, mi metto in attesa.
Alla fine dell'attesa (quindi ci sono oggetti disponibili) prendo il tempo nuovamente. Faccio una differenza con il tempo preso all'inizio e a questo punto ho due possibilità:

1) Il tempo di attesa è stato inferiore o al più uguale al numero di millisecondi di validità (passati al metodo)

2) Il tempo di attesa è stato superiore.

Nel caso 1 il mio oggetto è buono e lo ritorno. Nel secondo caso, lancio una bella eccezione di tipo TimeoutException.

Dici che può andare come idea?


Ciao.

[antig]

Così va bene ma il problema è che devo usare le classi Timer e TimerTask(è un pezzo di una traccia di esame) di java.util forse per evitare di sospendermi fino alla fine dell'attesa.
In pratica se il timeout è già scaduto non attendo che qualcuno mi risvegli con notify()
quando c'è un oggetto nel buffer ma lancio prima l'eccezione .

Pensi si possa fare ?
Grazie
Antonio

[LeleFT]

Uhm... sì.
Non ho mai usato Timer e TimerTask, ma penso proprio che si possa fare.
Ad esempio puoi schedulare il lancio di una TimeoutException dopo che il tempo specificato come parametro è trascorso.


Ciao.