Discussion :

[Mengué georges]

Suite au pb posé http://www.developpez.net/forums/d91...deamon-thread/,
j'ai bâti ceci mais lors du test la trace dans la console ne répond pas à ce que j'attendais.

PB:
Création d'un Thread deamon -> t1
Création d'un Thread -> t2
Lancement de t1 puis t2

Console:
t1 s'exécute puis t2 s'exécute
alors que je pensais que l'exécution de t1 et de t2 devrai se chevaucher et t2 clôture t1 quelque soit le cas (ce qui correspond à mon besoin).

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
package librairie;
 
import java.util.TimerTask;
 
 
public class ThreadJournalier extends TimerTask{ 
 
	public ThreadJournalier(){
		System.out.println("Constructeur de ThreadJournalier");
		Thread t1 = new Thread(new DaemonThread());
		t1.setDaemon(true);
		Thread t2 = new Thread(new NormalThread());
		t1.setDaemon(false);
		t1.start();
		t2.start();
	}
 
	public void run(){
		System.out.println("Méthode run de ThreadJournalier"); 	
	}
}
 
//****************************************************************************************
 
class DaemonThread extends Thread{
 
	public DaemonThread(){
		//traitement information nouvelle version + évolutions
		System.out.println("Constructeur DaemonThread de class.DaemonThread");
		String[] uri = {"http://www......maint.xml",""};
		gestionEvolution.SimpleSaxParser.main(uri);
	}
 
	public void run(){
		System.out.println("Méthode run de class.DaemonThread");  	
	}
}
 
//****************************************************************************************
 
class NormalThread extends Thread{
 
	public NormalThread(){
		//
		System.out.println("Constructeur NormalThread de class.NormalThread");
		librairie.TraitementFtp.Traitement();
	}
 
	public void run(){
		System.out.println("Méthode run de class.NormalThread");  	
	}
}

J'ai besoin de vos lumières
Merci

[tchize_]

vu qu'il n'y a qu'un system.out.println dans tes run, donc un code qui s'exécute en quelque microsecondes, tu ne risque pas de voir des masses le chevauchement. En fait le premier thread aura déjà fini de travailler en parallèle du thread principal avant que le deuxième n'ai eu le temps de se lancer.


Remplace tes run par une boucle avec un sleep autour de tes system.out.println et là tu verra bien les chevauchements.

[Mengué georges]

OK tu penses que le délais de chargement et de traitement du fichier xml est si court que je ne verrais pas le chevauchement? pourtant il y a 10 rqtes sql à exécuter et une centaine de lignes à parser.

J'ai fais un test en invsersant les 2 class appelées par t1 et t2 et le pb est idem.

[jowo]

Bonjour,

En principe le traitement devrait se faire dans la méthode run tandis que ton cas, il est fait dans le constructeur.

Pourquoi t1 et t2 devraient-il se chevaucher? Existe-t-il une "synchro" entre les deux threads?

[tchize_]

OK tu penses que le délais de chargement et de traitement du fichier xml est si court que je ne verrais pas le chevauchement? pourtant il y a 10 rqtes sql à exécuter et une centaine de lignes à parser.

Tu ne fais pas ces traitement dans le run, dans le run je ne vois qu'un System.out.println. Les traitement du constructeur sont, naturellement, fait au moment du new.

[Mengué georges]

Bonjour
OK je me suis mélangé les pinceaux.
Question:
L'import et le traitement de mon pb doit se faire dans la méthode run si j'ai bien compris.
Actuellement j'effectue ce traitement via SAX. Si par la méthode run (t1) je lance le traitement en appelant la class existante, je crèe un autre thread (t3) qui ne sera pas cloturé par la fermeture du deamon t1.
Donc pour résoudre mon pb je doit importer mon fichier via t1 et ne lancer le traitement que lorsque t2 sera cloturé.

Merci pour vos éclaircissement

[tchize_]

heu j'ai absolument rien compris à ton message, je l'ai pourtant lu trois fois.

Tu fait ton import, puis tu fait ton traitement, le tout dans une même thread, à priori. Inutile d'essayer de faire le traitement dans un thread séparé, puisque tu ne peux pas faire ce traitement tant que tu n'a pas importé tes données (si j'ai bien tout compris).

[Mengué georges]

Dans le cas particulier que je veux traiter: appel du fichier, ouverture du flux et plantage serveur

Ce que je voulais dire c'est que je ne sais pas comment SAX importe et traite le fichier via XMLReader. Je lui passe une url et puis ?

Si j'enregistre et teste l'existance du fichier ou une fermeture normale du thread deamon (chargement ok), je peux lancer un traitement et pas de plantage.

[jowo]

en fonction du protocole (http:, file:, ...) il va ouvrir soit une connexion ou un fichier pour lire un flux de données. SAX doit probablement déléguer à une classe (URLConnection?) l'ouverture du flux .

Gères-tu correctement les exceptions pour mieux cerner l'origine du "plantage"?

[Mengué georges]

Oui elles sont gérées
Ce qui s'est passé c'est que dans le déroulement de la séquence de connexion l'appel a ce fichier est effectué directement. Comme le serveur hébergeur du fichier s'est planté (pb de mémoire je pense), la séquence de connexion s'est arrêtée à ce point => blocage de l'appli sur la page de connexion plutôt que plantage.