Comment démarrer mon Thread une fois mort ?

**alextomas** · 02/07/2011, 18h30

Bonjour,

je lance mon thread comme suit :

Code :

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

1
2
3
4
5
6
void run()
{
     while (true){
         traitement();
     }
}

Est-ce que le fait de catcher une exception dans la méthode de run() me permet de redémarrer mon thread une fois qu'il est mort ?

Merci de votre aide.

**tchize_** · 02/07/2011, 18h57

un thread ne démarre qu'une fois, et ca n'a absolument rien à voir avec les exceptions. Si tu ne veux pas que le thread s'arrête, ne sort pas de la méthode run()

**alextomas** · 02/07/2011, 20h00

Envoyé par tchize_

un thread ne démarre qu'une fois, et ca n'a absolument rien à voir avec les exceptions. Si tu ne veux pas que le thread s'arrête, ne sort pas de la méthode run()

Merci de votre réponse.

En fait, dans mon programme, une exception se produit dans la méthode "traitement" appelée à partir de la méthode de run();

Code :

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

1
2
3
4
5
6
void run()
{
while (true){
traitement}
}
}

Donc la requête appelée dans la méthode de traitement n'est pas exécutée, est-ce que le thread est mort à ce moment ?

Et moi je veux que cette requête s'exécute tout le temps.
Comment faire?
merci

**Laurent.B** · 02/07/2011, 21h45

Bonjour,

Tant que l'exécution ne sort pas de la méthode run(), ton Thread est toujours actif.
Cf. http://alwin.developpez.com/tutorial/JavaThread/

**alextomas** · 03/07/2011, 15h58

Envoyé par Laurent.B

Bonjour,

Tant que l'exécution ne sort pas de la méthode run(), ton Thread est toujours actif.
Cf. http://alwin.developpez.com/tutorial/JavaThread/

Merci de votre réponse.

En fait, voici le log :

java.lang.NullPointerException
at oracle.jdbc.driver.OracleStatement.clearDefine(OracleStatement.java:1335)
at oracle.jdbc.driver.OracleStatement.end_of_result_set(OracleStatement.java:2998)
at oracle.jdbc.driver.OracleResultSetImpl.internal_close(OracleResultSetImpl.java:688)
at oracle.jdbc.driver.OracleResultSetImpl.next(OracleResultSetImpl.java:231)
at monpakage.maClasse.traitement(Unknown Source)
at monpakage.maClasse.run(Unknown Source)
at monpakage.maClasse.Emploi(Unknown Source)

Voici le code de démarrage de mon thread

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import Emploi;
 
public class LoadServletsaga extends HttpServlet {
 
    public void init() throws ServletException {
 
        try {
            Emploi  threadEmploi = new Emploi();
            threadEmploi.start();
        } catch (Throwable ex) {
            System.err.println("Initial SessionFactory creation failed." + ex);
            throw new ExceptionInInitializerError(ex);
        }
    }
}

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
public class Emploi extends Thread {
 
    private int limit=10;
    int i=0;
 
    private String SQL ="select ID  from emploi where flag is null";
 
    private static int nbThreads = 0;
 
    public Emploi () {
        nbThreads++;
    }
    public void run() {
        while (true) {
            this.traitement();
        }
    }
 
    private String traitement() {
 
            try {
                resultSet = this.queryDB(this.SQL);
            }
            catch (Exception ex1) {
                log.error("Open Resultset exception dans conection" + ex1.getMessage() +  "/" + ex1.getCause());
                goSleep();
                ConnectionFactory.resetConnection();
                return traitement();
            }    
 
            try {
                if ( (resultSet == null) || (!resultSet.next())) {
                    goSleep();
                    return "";
                }
 
                id = resultSet.getString(1);
 
                if ( (id == null))  {
                    goSleep();
                    return "";
                }
            } 
            catch (SQLException e) {
 
                log.error("Exception ");
                goSleep();                
                return traitement();
            }
 
            // methode comme paramerre "id"
            getMethode(id);
 
            // set counter to sleep 
            i=0;
 
        return resultFull;
    }
 
    private ResultSet queryDB(String sRequete) {
        ConnectionFactory factory=null;
        try {
             factory = new ConnectionFactory();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
        ResultSet rsQuery = null;
            log.debug("Request: " + sRequete);
            rsQuery = factory.queryDB(sRequete);
 
        return rsQuery;
    }
 
    public void goSleep(){
 
        try {
            if (i==0) {
                log.info("sleeping ... ");
                i++;
            }
 
            Thread.sleep(10000);
        } 
        catch (Exception ex1) {
            log.error("Exception thread: " + ex1.getMessage() +  "/" + ex1.getCause());
        }
    }
}

D’après les logs, quelle peut être l'origine du problème et comment puis-je le résoudre ?

Merci d'avance.

**Rei Ichido** · 04/07/2011, 10h48

Où est déclaré ton resultSet ? Là il ne l'est nulle part. Et son scope semble trop important par rapport au 1er try / catch de la méthode traitement : s'il y a eu un gros problème sur la récupération du resultSet, pas la peine d'essayer de faire des choses dessus ensuite.

Il y a une erreur loggée auparavant ?

**alextomas** · 04/07/2011, 16h58

Envoyé par Rei Ichido

Où est déclaré ton resultSet ? Là il ne l'est nulle part. Et son scope semble trop important par rapport au 1er try / catch de la méthode traitement : s'il y a eu un gros problème sur la récupération du resultSet, pas la peine d'essayer de faire des choses dessus ensuite.

Il y a une erreur loggée auparavant ?

merci de votre réponse.

en fait, j'ai oublié de mentionner que resultSet ; est initialiser au debut de classe comme suit :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
public class Emploi extends Thread {
 
    private int limit=10;
    int i=0;
    	ResultSet resultSet = null ; 
    private String SQL ="select ID  from emploi where flag is null";
 
    private static int nbThreads = 0;
 
    public Emploi () {
        nbThreads++;
    }
    public void run() {
        while (true) {
            this.traitement();
        }
    }
 
    private String traitement() {
 
            try {
                resultSet = this.queryDB(this.SQL);
            }
            catch (Exception ex1) {
                log.error("Open Resultset exception dans conection" + ex1.getMessage() +  "/" + ex1.getCause());
                goSleep();
                ConnectionFactory.resetConnection();
                return traitement();
            }    
 
            try {
                if ( (resultSet == null) || (!resultSet.next())) {
                    goSleep();
                    return "";
                }
 
                id = resultSet.getString(1);
 
                if ( (id == null))  {
                    goSleep();
                    return "";
                }
            } 
            catch (SQLException e) {
 
                log.error("Exception ");
                goSleep();                
                return traitement();
            }
 
            // methode comme paramerre "id"
            getMethode(id);
 
            // set counter to sleep 
            i=0;
 
        return resultFull;
    }
 
    private ResultSet queryDB(String sRequete) {
        ConnectionFactory factory=null;
        try {
             factory = new ConnectionFactory();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
 
        ResultSet rsQuery = null;
            log.debug("Request: " + sRequete);
            rsQuery = factory.queryDB(sRequete);
 
        return rsQuery;
    }
 
    public void goSleep(){
 
        try {
            if (i==0) {
                log.info("sleeping ... ");
                i++;
            }
 
            Thread.sleep(10000);
        } 
        catch (Exception ex1) {
            log.error("Exception thread: " + ex1.getMessage() +  "/" + ex1.getCause());
        }
    }
}

merci

**Rei Ichido** · 04/07/2011, 17h39

Il n'y a aucune raison à déclarer resultSet comme membre de classe, ça ne peut que générer des problèmes !
Ôte donc déjà cette déclaration au niveau de la classe, et rajoute le dans la méthode :

Code :

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

1
2
3
4
5
6
7
 
private String traitement() {
    ResultSet resultSet = null; 
            try {
                resultSet = this.queryDB(this.SQL);
            }
// ...

**alextomas** · 04/07/2011, 17h50

Envoyé par Rei Ichido

Il n'y a aucune raison à déclarer resultSet comme membre de classe, ça ne peut que générer des problèmes !
Ôte donc déjà cette déclaration au niveau de la classe, et rajoute le dans la méthode :

Code :

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

1
2
3
4
5
6
7
 
private String traitement() {
    ResultSet resultSet = null; 
            try {
                resultSet = this.queryDB(this.SQL);
            }
// ...

en fait, j'ai fait la modification ResultSet resultSet = null; dans la methode traitement, mais j'ai tjs le même le probleme d'arrêt de thread.

message erreur suivant :
***********exception dans traitement**********

voici le code :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
public void run() {
        while (true) {
try {
            this.traitement();
}
catch (Exception ex) {
log.debug("***********exception dans traitement**********");
goSleep();}
 
	}
        }
    }

est ce que l'exception est produite dans run() ou bien la méthode de traitement?

merci

**Rei Ichido** · 05/07/2011, 10h13

L'exception est produite dans ta méthode de traitement, n'y est pas catchée, et donc se propage dans ta méthode run, où elle est interceptée de manière inefficace, ie sans qu'on puisse savoir ce qui pose problème. Au minimum le catch doit inclure le log du message de l'exception, et il est plus efficace de faire un e.printStackTrace si tu veux vraiment savoir ce qui pose problème.

**alextomas** · 05/07/2011, 12h26

Envoyé par Rei Ichido

L'exception est produite dans ta méthode de traitement, n'y est pas catchée, et donc se propage dans ta méthode run, où elle est interceptée de manière inefficace, ie sans qu'on puisse savoir ce qui pose problème. Au minimum le catch doit inclure le log du message de l'exception, et il est plus efficace de faire un e.printStackTrace si tu veux vraiment savoir ce qui pose problème.

bonjour,

merci de votre réponse.

L’exception dans la méthode traitement est à cause de la fermeture de connexion.

En fait, dans la méthode traitement, j'appelle la méthode queryDB suivante :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
public ResultSet queryDB(String requete) {
        ResultSet rsQuery = null;
        private static Statement sta = null;
        try {
           log.debug("Request: " + requete);
            rsQuery = sta.executeQuery(requete);
        } catch (SQLException ex) {
            log.error("Error Request : " + ex.getCause() + " / "
                    + ex.getMessage());
 
        }
        return rsQuery;
    }

ma question comment je peux stopper la propagation de l'exception qui se produit dans la méthode traitement vers la méthode run()??

en plus, même j’appelle la méthode goSleep() pour dormir le thread ; il n’a aucun effet .

Merci d’avance.

**tchize_** · 05/07/2011, 21h53

via un catch, comme tout exception :/

**alextomas** · 08/07/2011, 21h15

Envoyé par tchize_

via un catch, comme tout exception :/

Bonjour,

en fait, j'ai changé le code comme suit :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
private ResultSet queryDB(String sRequete) throws SQLException  {
		ConnectionFactory factory=null;
		ResultSet rsQuery = null;
		try {
			log.debug("Request: " + sRequete);
			maconnection= new Connection();
			rsQuery = maconnection.queryDB(sRequete);
			}
			catch (SQLException e)
			{
				try
			    {
 
			        Thread.sleep (30000);
			    }
			    catch (InterruptedException exception){
			    	log.error("Exception sleep thread : "); 
			    	e.printStackTrace();
			    }	
			}
 
		return rsQuery;
	}

par contre, le thread mort avec exception suivante :

java.lang.NullPointerException
at oracle.jdbc.driver.OracleResultSetImpl.internal_close(OracleResultSetImpl.java:688)
at oracle.jdbc.driver.OracleResultSetImpl.next(OracleResultSetImpl.java:231)
at monpakage.maClasse.traitement(Unknown Source)
at monpakage.maClasse.run(Unknown Source)
at monpakage.maClasse.Emploi(Unknown Source)

ma question :
pourquoi l'exception est monté jusqu’à la méthode run() sachant que j'ai intercepté l'exception dans la méthode de queryDB.

merci d'avance.

**tchize_** · 08/07/2011, 21h33

il n'y a pas de catch NullPointerException dans votre methode query. De toutes facons, c'est une mauvaise idée de les attraper, ces exceptions dénottent en général un bug dans le logiciel. Controlez vos variable pour éviter ça

Comment démarrer mon Thread une fois mort ?

Concurrence et multi-thread Java

Discussions similaires

Partager

Partager