Discussion :

[nretrain]

Bonjour,
je fais des requetes sur différentes machines en parrallèle via un pool de thread. Il peut arriver qu'une machine ne me réponde pas, ou soit trop lente, dans ce cas j'aimerai pouvoir libérer le thread. au bout d'un certain temps.
voici ce que j'ai fait :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
ExecutorService threadExecutor = Executors.newFixedThreadPool( numberOfThreadMax );  
for(MonThread thread : threadList)
    threadExecutor.execute( thread ); 
 
//no more thread to add to the pool so we close the pool
threadExecutor.shutdown(); 
//and we wait the end of each thread in the pool	
try {
      threadExecutor.awaitTermination(threadTimeOut, TimeUnit.SECONDS)	
} 
catch (InterruptedException e) {
logger.error(e);
throw new ServerErrorException();
}

le problème est que le awaitTermination me donne un timeout sur le pool et non pas pour chaque thread.
Merci de votre aide

[kolodz]

Bonjour,

Ce n'est pas plutôt dans le "run" de tes Thread que tu devrait vérifier si ton timeout se déclenche ?

En toute logique à chaque requête tu va avoir un timeout.
Si sur une requête l'un de ces timeout se déclenche, tu réalise un stop sur le Thread. Ou tu prévient le Thread principale que tu es libre.
Ce qui permettrai une réaffections dynamique des Thread par exemple.

Cordialement,
Patrick Kolodziejczyk.

[adiGuba]

Salut,


Pour attendre un thread spécifique, tu dois utiliser la méthode submit() à la place d'execute(). Cela te permettra de récupérer un objet Future qui te permettra d'attendre sa fin via la méthode get(long,TimeUnit)



Maintenant, pour interrompre le thread cela dépend beaucoup du code de ce dernier. Donc le timeout devrait être géré à ce niveau...


a++

[nretrain]

Oui j'ai pensé à la solution de mettre le timeout dans le "run" de chaque thread; mais j'aurais préféré centraliser tout et laisser le pool prendre les décisions.
Si il n'y a pas de solution je ferai ça

[kolodz]

Si un Thread prévient le Thread principale, c'est toujours le Thread principale qui prendra la décision de ce qu'il faut faire.
Tu serai d’ailleurs plus précis sur le timeout (au niveau des requête et non au niveau du thread en globale)