[JSP] - Perdo il controllo di un thread

[clockover]

Come da titolo!

Ho una pagina jsp molto semplice che nella sua fase di init (jspInit()) chiama un thread, il quale si mette in ascolto di una serversocket! Il thread in questione è un qualcosa del tipo

while(true){
    Socket sock = null;
    sock = serversocket.accept();
    exs.submit(unThreadPerLaRicezione(sock));
}

dove exs è un ExecutorService!

nella fase di destroy della Servlet (jspDetroy()) eseguo alcune operazioni quali chiusura del FileWriter del log, ecc... quando voglio chiudere anche il thread che è in ascolto eseguo una cancel(true) dato che il thread è rappresentato da una Future

Future ft = exs.submit(threadServer);
....
.....
void jspDestroy(){
    ft.cancel(true);
}

Il problema è che andando a leggere il log di tomcat ho scoperto che il thread che ho cercato di uccidere è ancora li!
Questo è quello che mi dice netbeans

GRAVE: The web application [/App] appears to have started a thread named [pool-1-thread-1] but has failed to stop it. This is very likely to create a memory leak.

Ho fatto anche altre prove, ad esempio un altro thread che a scadenza regolare, tipo di un secondo, scrive su un file qualcosa! Quando viene eseguita la destroy questo thread di prova finisce, mentre quello in ascolto sulla ServerSocket è ancora attivo!


Cosa mi sfugge da questa situazione?

edit:
anche quando chiudo Tomcat il thread rimane attivo

[banryu79]

Originariamente inviato da clockover

Cosa mi sfugge da questa situazione?

La chiamata a Future.cancel(true) non termina veramente l'esecuzione del thread, semplicemente segnala al thread in questione di terminare il prima possibile (il fatto di passare true come parametro indica al Future che deve settare a true il flag per l'interrupt del thread, ma pure questo non causa una terminazione immediata del thread).

Bisogna quindi che il thread, nel suo flusso di esecuzione, dia supporto alle eventuali richieste di interrupt/cancellazione che gli arrivano.
Ci sono vari modi per farlo.

A questa vecchia discussione nei miei messaggi (dal #16 in poi) trovi delle info in merito (roba che trovi tranquillamente nella documentazione/tutorial della Sun[ops... Oracle]), non so quale sia il tuo livello di competenze quindi scusa in anticipo se ti indico un thread che contiene roba che già conosci.

Comunque il succo è: controlla cosa fa il tuo thread, e vedi se supporta "correttamente" le richieste di interruzione.

[clockover]

Anche in rete ho trovato soluzioni simili a quelle che hai scritto nel tuo vecchio post! E in effetti le ho utilizzate e si sono rivelate funzionali! Il fatto è che il thread rimane bloccato in attesa di una connessione con l'esterno! Potrei inserire un timeout, ma non mi sembra una soluzione particolarmente efficiente!

Ho trovato questa discussione! Sembra simile al mio problema!
http://stackoverflow.com/questions/1...rsocket-accept

Faccio un po di tentativi!

ps
le mie competenze sono sicuramente molto poche

[clockover]

In effetti sembra funzionare adesso! Quindi la chiusura della ServerSocket mi fa scatenare una IOException all'interno del thread e gestendola posso chiudere il thread! Mi mandava in confusione la future.cancel()!
Dunque devo essere capace di gestire per ogni thread un meccanismo di chiusura altrimenti me lo ritrovo sempre in vita!

[banryu79]

Umm... interessante, ho letto il link che hai postato.
Se non vuoi optare per la ServerSocketChannel (che risponde agli interrupt) e vuoi continuare ad usare ServerSocket (che invece oltre a essere bloccante pare pure ignorarli finchè non termina) devi ingegnarti con qualche "barbatrucco".

La prima cosa che mi viene in mente, e forse ci hai già pensato anche tu, è il fatto di incapsulare l'operazione di accept con un timeout in un ciclo.
Il cilco termina "normalmente" solo quando la accept ha esito positivo, e quindi si è stabilita una connessione.
La accept però è vincolata ad un timeout: quando il timeout scade controlli se il flag di interrupt del Thread corrente è stato settato, nel qual caso lanci a tua volta una InterruptedException; altrimenti non fai nulla e il cilco continua allegramente.

@EDIT:

In effetti sembra funzionare adesso! Quindi la chiusura della ServerSocket mi fa scatenare una IOException all'interno del thread e gestendola posso chiudere il thread! Mi mandava in confusione la future.cancel()!

Ah ecco, mi pareva strano: allora è decisamente meglio non "barbatruccare" niente e fare così

Dunque devo essere capace di gestire per ogni thread un meccanismo di chiusura altrimenti me lo ritrovo sempre in vita!

Esattamente. Bisogna essere vigili

[clockover]

Comunque avevo già fatto un tentativo del genere, cioè chiudendo la ServerSocket, ma probabilmente mi ero dimenticato di gestire l'eccezione e quindi stavo punto e accapo, anzi era pure peggio perchè dovevo chiudere poi con cattiveria!

Grazie per i suggerimenti banryu