Threading et exception?

Threading et exception? - Java - Programmation

Marsh Posté le 20-11-2006 à 18:17:01    

Bonjour,
Je dois faire un programme qui verifie la disponibilité et le bon fonctionnement d'un outil :
Soit TraitementLong la classe qui fait tous les tests.
 
L'un des problème que je dois gérer est la mauvaises prise en compte de TraitementLong des TimeOut.
 
Pour cela je crée un Thread qui lance un TimeOut en même qu'un thread qui qui lance TraitementLong.
 
 
Voila le code :
 
 

Code :
  1. package ppaceMaker;
  3. import org.apache.log4j.Logger;
  4. import org.apache.log4j.PropertyConfigurator;
  6. import utilities.Mailing;
  7. import utilities.PPlus;
  8. import utilities.Utils;
  9. import utilities.Timer;
  11. import com.sciforma.psnext.api.PSException;
  13. public class ConnectionDiagnosis_V5 extends Timer {
  15. static final long start = System.currentTimeMillis();
  17. static long now = start;
  19. final boolean OK = true;
  21. private static int TIME_OUT = 5;
  23. private static final Logger logger = Logger.getLogger("PACEMAKER" );
  25. static boolean timeOut = false;
  27. static boolean success = false;
  29. public ConnectionDiagnosis_V5(int arg0) {
  30.  super(arg0);
  31.  // TODO Auto-generated constructor stub
  32. }
  34. private synchronized static void lanchtest() throws PSException {
  35.  PPlus mytest = new PPlus(true, true);
  36.  mytest.closeSession();
  37. }
  39. static Thread tpplus = new Thread(new Runnable() {
  40.  public void run() {
  41.   // le code qui te prend du temps
  42.   try {
  43.    lanchtest();
  44.    success = true;
  45.    tcounter.interrupt();
  46.   } catch (Exception e) {
  47.    e.printStackTrace(); // eventuelle
  48.   }
  49.  }
  50. });
  52. static Thread tcounter = new ConnectionDiagnosis_V5(TIME_OUT * 1000);
  54. synchronized public void timeout() {
  55.  System.err.println("ICI?" );
  56.  // Erreur de TO
  57.  logger.error("PPlus Timeout occurred.... terminating" );
  58.  /*
  59.   * Utils.timeIt(now); // this.stop();
  60.   * Mailing.sendMail("xxxxx@sgcib.com",
  61.   * "xxxxx@sgcib.com", "Time Out Problem!!!", "Attention avec
  62.   * la copyProd" ); try { Thread.sleep(1000); } catch
  63.   * (InterruptedException e) { // TODO Auto-generated catch block
  64.   * logger.error(e); } this.stop();
  65.   */
  66.  tpplus.interrupt();
  67.  timeOut = true;
  68.  this.stop();
  69. }
  71. public static void checkJobDate() {
  73. }
  75. public static void main(java.lang.String[] args) {
  77.  PropertyConfigurator.configure(ConnectionDiagnosis.class
  78.    .getClassLoader().getResource("conf/log4j.properties" ));
  79.  logger.info("Starting Diagnosis" );
  81.  tcounter.start();
  82.  tpplus.start();
  84.  while (!timeOut) {
  86.  }
  88.  logger.info("Ending Diagnosis" );
  89.  Utils.timeIt(start);
  90. }
  91. }


Message édité par PETOZAK le 01-10-2007 à 11:31:08
Reply

Marsh Posté le 20-11-2006 à 18:17:01   

Reply

Marsh Posté le 20-11-2006 à 18:17:15    

Mon problème est simple:
 
 
Comment récupérer les interruptions de Thread (java.lang.InterruptedException) pour pouvoir lancer le traitement voulu. Dans mon cas :
 
Si Time out se produit : Tuer Thread et Envoyer Mail depuis le Main.
 
 
Il est à noter que les 2 threads doivent s'interrompre , en effet :
Si TraitementLong < TimeOut alors je dois tuer TimeOut et envoyer un mail positif
 
TraitementLong > TimeOut alors je dois tuer TimeOut et envoyer un mail négatif

Reply

Marsh Posté le 20-11-2006 à 18:17:26    

Est ce que join peut m'aider?

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed