Discussion :

[slim]

salut tout le monde,

j'ai fais un petit programme utilisant les threads. J'ai cree une classe producteur, consommateur, filemessages et main.
j'ai un petit probleme dans l'utilisation de la classe filemessages dans les classes producteur et consommateur. En effet, je declare un vecteur statique file dans la classe filemessages et dans les classes prod et cons, je declare une variable de type filemessages. Resultat : j'ai une erreur dans les deux classes prod et cons disant que file n'est pas reconnu alors que c'est un vecteur statique...

pourriez-vous m'aider s'il vous plait ?

consommateur :

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
import java.lang.Object;
import java.lang.Thread;
import java.util.Vector;
 
public class consommateur implements Runnable{
	private Thread monThread;
	private String nom;
 
	public void demarrer(){
		if(monThread == null){
			monThread = new Thread(this);
			monThread.start();
		}
	}
	public void arreter(){
		if(monThread.isAlive()){
			monThread.interrupt();
			monThread=null;
		}
	}
	public void run(){
		try{int i =0;
			while(! monThread.isInterrupted()){
				String mess = "message n° " + i;
				i--;
				[b]maFile[/b].retirer(mess);//l'erreur est là... il reconnait pas maFile
				monThread.sleep(200);
			}
		}catch(InterruptedException e){System.out.println("Interruption !");}
	}
}

Producteur :

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
import java.lang.Object;
import java.lang.Thread;
import java.util.Vector;
 
public class producteur implements Runnable {
	private Thread monThread;
//	private String nom;
	public void demarrer(){
		if(monThread==null){
			monThread = new Thread(this);
			monThread.start();
		}
	}
	public void arreter(){
		if(monThread.isAlive()){
			monThread.interrupt();
			monThread = null;
		}
	}
	/* (non-Javadoc)
	 * @see java.lang.Runnable#run()
	 */
	public void run(){
		try {
			int i =0;
			while(!monThread.isInterrupted()){
				String mess = "message n° "+i;
				i++;
				[b]maFile[/b].inserer(mess);
				monThread.sleep(200);
			}
		}catch(InterruptedException e){
			System.out.println("Interruption !");
		}
	}
}

filemessages :

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
import java.lang.Object;
import java.lang.Thread;
import java.util.Vector;
 
public class filemessages {
	static final int taillemax = 30;
	static Vector maFile;
	public filemessages(){
		maFile= new Vector();
	}
	public synchronized void inserer (String m)throws InterruptedException{
		while(maFile.size()==taillemax){
			System.out.println("Wait...");
			wait();
		}
		maFile.addElement(m);
		System.out.println("Signal !");
		notify();
	}
	public synchronized String retirer()throws InterruptedException{
		while(maFile.size()==0){
			System.out.println("Wait...");
			wait();
		}
		String mess = (String)maFile.firstElement();
		maFile.removeElement(mess);
		notify();
		System.out.println(mess);
		return mess;
		}
}

merci beaucoup.

[anykeyh]

static Vector maFile;
->
public static Vector maFile;

[slim]

merci mais ca marche pas...

P.S. : j'utilise Eclipse.

[jowo]

maFile doit être publique (c'est fait) mais pour reconnaître cette variable statique, tu dois indiquer aussi le nom de la classe.

Code :

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

filemessages.maFile

Encore une remarque si tu permets. Par convention (aucune obligation), les noms des classes commencent par une majuscule.

Code :

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

1
2
3
FileMessages
Producteur
Consommateur

[slim]

merci beaucoup.

du coup, avec public static void et FileMessages.maFile etc. ca ne me met plus d'erreur mais

Code :

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

FileMessages.maFile.retirer(mess)

me provoque une erreur parce que retirer n'est pas une methode du vecteur.

J'ai donc cree une instance publique et statique de FileMessages dans Main pour pouvoir l'utiliser à la place de maFile (le vecteur) dans le prod et le conso mais ca marche pas non plus

Main :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
public class Main {
	public static filemessages File = new filemessages();
	public static void main(String[]args){
		producteur p1=new producteur();
		producteur p2 = new producteur();
		consommateur c1=new consommateur();
		consommateur c2 = new consommateur();
		filemessages file = new filemessages ();
		long debut = System.currentTimeMillis();
		p1.demarrer();
		c1.demarrer();
	}
}

merci

[let_me_in]

public synchronized String retirer()throws InterruptedException{
while(maFile.size()==0){
System.out.println("Wait...");
wait();
}
String mess = (String)maFile.firstElement();
maFile.removeElement(mess);
notify();
System.out.println(mess);
return mess;
}

je ne sais pas si je dis du n'importe quoi, mais un wait() dans une methode synchronized : : :

[jowo]

;-) let_me_in tu dis vraiment n'importe quoi.

Ne le prend pas mal, je ne fais que te répondre.

Plus sérieusement, la méthode wait ne peut être appelée que dans un bloque synchronisé... ;-)

[slim]

et sinon mon erreur ?

merci

[let_me_in]

Ne le prend pas mal, je ne fais que te répondre.

non, non c'etait vraiment con de ma part; j'avais meme utilise ca plusieurs fois en implementant la classe Semaphore !!!!!

et sinon mon erreur ? Embarassed Smile

merci

j'ai fais qq modifications et ca marche, mais la condition de l'interblocage n'est pas verifiee.

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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
 
import java.lang.Object;
import java.lang.Thread;
import java.util.Vector;
 
class consommateur implements Runnable{
   private Thread monThread;
   private String nom;
   filemessages fm=new filemessages();
 
   public void demarrer(){
      if(monThread == null){
         monThread = new Thread(this);
         monThread.start();
      }
   }
   public void arreter(){
      if(monThread.isAlive()){
         monThread.interrupt();
         monThread=null;
      }
   }
   public void run(){
      try{int i =0;
         while(! monThread.isInterrupted()){
            String mess = "message n° " + i;
            i--;
            fm.retirer();
            monThread.sleep(200);
         }
      }catch(InterruptedException e){System.out.println("Interruption !");}
   }
}
 
class producteur implements Runnable {
   private Thread monThread;
//   private String nom;
   filemessages fm=new filemessages();
 
   public void demarrer(){
      if(monThread==null){
         monThread = new Thread(this);
         monThread.start();
      }
   }
   public void arreter(){
      if(monThread.isAlive()){
         monThread.interrupt();
         monThread = null;
      }
   }
   /* (non-Javadoc)
    * @see java.lang.Runnable#run()
    */
   public void run(){
      try {
         int i =0;
         while(!monThread.isInterrupted()){
            String mess = "message n° "+i;
            i++;
            fm.inserer(mess);
            monThread.sleep(200);
         }
      }catch(InterruptedException e){
         System.out.println("Interruption !");
      }
   }
}
 
 
class filemessages {
   static final int taillemax = 30;
   static Vector maFile;
   public filemessages(){
      maFile= new Vector();
   }
   public synchronized void inserer (String m)throws InterruptedException{
      while(maFile.size()==taillemax){
         System.out.println("Wait...");
         wait();
      }
      maFile.addElement(m);
      System.out.println("Signal !");
      notify();
   }
   public synchronized String retirer()throws InterruptedException{
      while(maFile.size()==0){
         System.out.println("Wait...");
         wait();
      }
      String mess = (String)maFile.firstElement();
      maFile.removeElement(mess);
      notify();
      System.out.println(mess);
      return mess;
      }
}
 
public class Tp1{
	public static void main(String[] arg){
		new producteur().demarrer();
		new consommateur().demarrer();
 
	}
 
}

[slim]

merci

mais si tu declare dans le prod et le cons une variable de type Filemessages, ca va pas etre là meme... ? c'est pour ca que je voulais utiliser un vecteur statique dans la classe filemessages.

[let_me_in]

merci

mais si tu declare dans le prod et le cons une variable de type Filemessages, ca va pas etre là meme... ? c'est pour ca que je voulais utiliser un vecteur statique dans la classe filemessages.

t'as raison oui, voici le nouveau:

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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
 
import java.lang.Object;
import java.lang.Thread;
import java.util.Vector;
 
class consommateur implements Runnable{
   private Thread monThread;
   private String nom;
   filemessages fm;
 
   public consommateur(filemessages fm){
   	this.fm=fm;
   }
 
   public void demarrer(){
      if(monThread == null){
         monThread = new Thread(this);
         monThread.start();
      }
   }
   public void arreter(){
      if(monThread.isAlive()){
         monThread.interrupt();
         monThread=null;
      }
   }
   public void run(){
      try{int i =0;
         while(! monThread.isInterrupted()){
            String mess = "message n° " + i;
            i--;
            fm.retirer();
            monThread.sleep(200);
         }
      }catch(InterruptedException e){System.out.println("Interruption !");}
   }
}
 
class producteur implements Runnable {
   private Thread monThread;
//   private String nom;
   filemessages fm;
 
   public producteur(filemessages fm){
   	this.fm=fm;
   }      
 
   public void demarrer(){
      if(monThread==null){
         monThread = new Thread(this);
         monThread.start();
      }
   }
   public void arreter(){
      if(monThread.isAlive()){
         monThread.interrupt();
         monThread = null;
      }
   }
   /* (non-Javadoc)
    * @see java.lang.Runnable#run()
    */
   public void run(){
      try {
         int i =0;
         while(!monThread.isInterrupted()){
            String mess = "message n° "+i;
            i++;
            fm.inserer(mess);
            monThread.sleep(200);
         }
      }catch(InterruptedException e){
         System.out.println("Interruption !");
      }
   }
}
 
 
class filemessages {
   static final int taillemax = 30;
   static Vector maFile;
   public filemessages(){
      maFile= new Vector();
   }
   public synchronized void inserer (String m)throws InterruptedException{
      while(maFile.size()==taillemax){
         System.out.println("Wait...");
         wait();
      }
      maFile.addElement(m);
      System.out.println("Signal !");
      notify();
   }
   public synchronized String retirer()throws InterruptedException{
      while(maFile.size()==0){
         System.out.println("Wait...");
         wait();
      }
      String mess = (String)maFile.firstElement();
      maFile.removeElement(mess);
      notify();
      System.out.println(mess);
      return mess;
      }
}
 
 
public class Tp1{
	public static void main(String[] arg){
		filemessages fm=new filemessages();
		new producteur(fm).demarrer();
		new consommateur(fm).demarrer();
 
	}
 
}