[JAVA] Processo a tempo

[topozizzo]

Salve, avrei bisogno di un consiglio:
Sto realizzando una sorta di p2p. La rete p2p e' organizzata così:
Peer e Leader, i leader formano un gruppo multicast tra loro. A ciascun leader sono connessi dei peer.
Un peer può fare una richiesta con tcp al Leader a cui e' connesso; il Leader controlla se ha la risposta nella cache, se si risponde direttamente, altrimenti innoltra la richiesta nella rete multicast agli altri leader che se hanno la risposta la innoltrano nelle rete multicast.

Insomma:
Domanda
Risposta 1
Risposta 2
.
.
Risposta N

Il problema sorge adesso... Siccome le risposte possono essere molteplici, come posso fare in modo che il peer sappia in qualche modo che non ci sono più risposte per lui????

Non riesco proprio a trovare una soluzione, anche perchè mentre il client attende su tcp col socket aperto non può sapere ne quante risposte gli arriveranno, ne se ne arriveranno.

Io stavo pensando di fare in modo che l'ascolto delle risposte sia delegato a un Thread attivo per un tempo stabilito(N secondi) e poi terminato(quello che ha letto bene, il resto pazienza), ma non so come mettere in pratica quest'idea. All'inizio pensavo a timerTask, ma questa classe non fa altro che schedulare in processo dopo un timeout.... Io invece lo voglio terminare al timeout. A complicare il tutto c'è il fatto che una risposta potrebbe arrivare a socket già chiuso e processo già terminato
(e li sono eccezioni che volano)

Avete qualce idea alternativa per risolvere il mio problema?

[franksisca]

scusa, ma nopn potresti mettere una stringa speciale di chiusura???

l'idea del thread comunque può andare bene lo stesso.

[topozizzo]

Ci ho pensato anche io, ma il fatto e' che non posso sapere quanti sono a priori i pacchetti che arriveranno dalla rete multicast. A dire il vero non posso sapere neanche se ne arriveranno. Mi sa che sono in vicolo cieco...

Ho provato una soluzione (nel client ) tipo leggere per un tot di volte dal socket catturando una timeout exception

for(...n volte.....){
try{

Leggi dal socket();

}catch(TimeoutException e){}
}

Ma se nessuno scrive, cattura seplecemente n eccezioni del tipo IOException(tante quante le iterazioni del for) e poi non legge niente, senza far partire il timeout(Il timeout parte solo se legge almeno una volta, e questo nn me lo spiego ).

[franksisca]

ma che ti interessa a fare sapere a priori quanto pacchetti devono arrivarti???

[topozizzo]

Beh, cosi posso mandare al client un messaggio con scritto END appena arriva l'ultimo pacchetto... e lui tutto felice chiude il socket e se ne va...

Potrei provare a mandare il messaggio di End dopo un tot di secondi....
(Ma se qualche altro processo sta scrivendo sul socket???).

Bel casino...