Discussion :

[tiamat]

Bonjour à tous,

j'ai un petit problème de wait sur un Thread qui même après un appel de la méthode notify ne se débloque pas...

voici le code de la casse 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
18
19
20
21
 
public class USBThread extends Thread{
...
 
	public static USBThread getInstance(){
	    if( instance == null ) { instance = new USBThread(); }
	    return instance;
	}
 
	public void run(){
                .......
		while(fin != 1){
			synchronized(this){
				try{
					this.wait();
					log.debug("Traitement du message");
                                        process();
 
				}catch(Exception e){}
			}
		}

et voici la classe qui utilise ce thread.
En fait je crée un objkect USBThread, je récupère sa référence, je modifie un de ses objet et je notifie le thread pour qu'il puisse processer mon objet envoyé:

Code :

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

1
2
3
4
5
6
7
 
                        USBThread usb = USBThread.getInstance();
 
			synchronized(usb){
				usb.sendCommand(commande);
				usb.notify();
			}

lorsque cette classe appelle la méthode notify de mon threadUSB, je n'ai pas d'affichage de la chaine "Traitement du message", ni de lancement de la méthode process().

Quelqu'un pourrait m'éclairer à ce sujet ? je bloque....

Merci !
Tiamat.

[adiGuba]

Salut,


Question bête mais : le thread est-il bien lancé ?
Sinon avec Java 5 tu peux utiliser une BlockingQueue pour cela


a++

[tiamat]

Salut adiGuba,

oui je te confirm que le Thread est bien lancé car j'effectue une initialisation dans le Thread avant de pouvoir processer mes commandes (ouverture du port USB).

Je vais regarder les Blocking Queue, mais étant donné que mon besoin reste assez basique, je sais que je n'aurais toujours qu'un seul thread USB, le seul truc c'est que c'est lui qui est garant de la connection USB et toute demande de traitement de commande doit passer par lui...

pour moi la boucle infinie en attente de notify() semblait une solution parfaite pour mettre le Thread en attente de processing de commande...

[adiGuba]

pour moi la boucle infinie en attente de notify() semblait une solution parfaite pour mettre le Thread en attente de processing de commande...

Comme tu ne peux pas déterminer l'ordre d'exécution des threads, il est possible que le notify() soit exécuté AVANT le wait() : du coup ton thread s'endort et ne se réveille plus....


Il faudrait rajouter un double-check qui vérifie s'il y a des données avant le wait()...



Mais les BlockingQueue sont justement là pour résoudre ce problème :

• Un thread fait une boucle pour récupérer les éléments de la queue :
  

  Code :

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

  1
  2
  3
  4
  5
  while (true) {
      String cmd = queue.take(); // bloquant si vide
   
      // Traitement de "cmd"
  }

• Les autres threads pouvant à tout moment envoyer des données dans la queue, qui seront donc traiter dès que possible :
  

  Code :

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

  queue.offer( commande );

a++

[tiamat]

j'ai un peu regardé les BlockingQueue mais au plus j'y réfléchis au plus je me dit que l'utilisation des Thread "standards" est largement suffisante pour mon besoin (en tout cas pour le moment)...

donc je tente d'investiguer un peu plus sur mon problème...ça doit marcher !

du fait ta remarque sur l'ordre entre le notify et le wait est obligatoirement bon dans mon soft, mon Thread se met en wait() au démarrage de mon programme et je suis persuadé que que le notify arrive après.

donc si j'énumère:
- je suis sur que c'est le même Thread à qui j'envois un notify (en affichant la ref du Thread j'ai vu que c'est le même instancié au début et celui à qui j'envois un notify)
- je n'ai pas d'exception, j'ai juste mon thread qui n'est jamais réveillé

Avez vous une idée ? si vous voulez je peux vous faire passer un peu plus de code pour expliquer un peu mieux !

Merci,
Tiamat.

[tchize_]

met un log avant le wait(), pour être sur.
met un log avant le notify(), pour etre sur aussi.
a mon avis, soit le thread est pas lancé, soit le notify arrive trop tot par rapport au wait, soit tu fait pas le notify, soit encore t'as plusieurs trucs qui font un wait sur le meme objet

et en multi threading, on ne peut pas être persuadé qu'un notify arrive bien après un wait, il faut en etre sur, et ton code n'en donne aucune garantie

[Mister-Joker]

Salut,


Question bête mais : le thread est-il bien lancé ?


a++

Il n'y a aucun appel de la méthode start() pour lancer le thread.

[Mister-Joker]

Salut:

Code :

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

1
2
3
4
5
6
7
public static USBThread getInstance(){
     if( instance == null || !instance.isAlive())  { 
          instance = new USBThread();
          instance.start();
     }
     return instance;
}