Discussion :

[nevroo]

Bonjour,
bon voilà mon probleme, je tente de synchroniser deux treads, alors j'ai une class Inf qui affiche un text divisé en deux morceaux, séparé par un laps de temps,donc dans ce sens :

affichage partie 1 du texte
attente de 2 sec
affichage partie 2 du txt

donc c'est tres simple,tout se complique ici, je lance ce petit code avec deux threads distinct, donc thread a et thread b , le probleme est que quand je lance le thread a, je veux que le thread b attende que le thread a soit fini.


A priori, avec synchronized; le thread b ne peut pas acceder au thread princiapal tant que celui ci n'est pas fini, mais ça ne marche pas :

voici mon code :

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
public class Inf implements Runnable{
 
	protected String text;
	protected String number;
 
	public Inf(String text){
		this.text  = text;
	}
 
	public void run(){
		while(true){
			try{
					Thread.sleep(10);
			}catch(InterruptedException e){ System.out.println(e);	}
			displayAll();	
		}
	}
 
 
	public synchronized void displayAll(){
		displayPartOne();
		try{
			Thread.sleep(2000);
		}catch(InterruptedException e){ System.out.println(e);	}
		displayPartTwo();
	}
 
	public synchronized void displayPartOne(){
		System.out.print(textPartOne());
	}
 
	public synchronized void displayPartTwo(){
		System.out.println(textPartTwo());
	}
	public String textPartOne(){
		String res="";
		for(int i=0;i < text.length()/2;i++){
			res += text.charAt(i);
		}
		return res;
	}
 
	public String textPartTwo(){
		String res="";
		for(int i=text.length()/2;i < text.length();i++){
			res += text.charAt(i);
		}
		return res;
	}
	// to help me for debuging	
	public void setNumber(String number){	this.number = number; }
 
	public String toString(){
		return "thread n  : "+number;
	}	
}

et la classe Client :

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
public class Client{
 
	public Client() throws Exception{
		Inf a = new Inf("Victor is a man");
		a.setNumber("1");
		Inf b = new Inf("Cleopa is a cat");
		b.setNumber("2");
 
		Thread ta = new Thread(a);
		Thread tb = new Thread(b);
		ta.start();
		tb.start();
	}
 
	public static void main(String [] args)  throws Exception{
		new Client();	
	}
}

laffichage est le suivant :

Victor Cleopa is a man
is a cat
Victor Cleopa is a man
is a cat
Victor Cleopa

on voit que victor devient un chat et cleop devient un homme..

le probleme est clair ici, a la premiere ligne, Victor et Cleopa accede a la methode display tous les deux, alors que je pensais que Cleopa ne pouvait pas s'afficher tant que Victor n'avait pas fini..

quelqu'un peut m'aider

[®om]

Ta synchronisation ne sert à rien ici, vu que le thread ta exécute les méthodes synchronisées sur l'objet a, et que le thread tb exécute les méthodes synchronisées sur l'objet b. Elles ne sont pas synchro "entre-elles".

De plus, même si tu les synchronisais entre-elles, tu n'as aucune garantie que ta soit exécuté avant b.
Dans ton cas (déjà pourquoi avoir 2 threads et non 1 seul?), tu lances ta (ta.start()), puis tu fais ta.join() avant de lancer tb (tb.start()). Comme ça tu attends que ta soit fini avant de lancer tb...

[nevroo]

techniquement ca devrait marcher hormis :

Code :

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

1
2
3
4
5
6
~/progs/Java/project2 $ java Client
Exception in thread "main" java.lang.IllegalMonitorStateException
        at java.lang.Object.wait(Native Method)
        at java.lang.Object.wait(Object.java:474)
        at Client.<init>(Client.java:12)
        at Client.main(Client.java:17)

[®om]

Tu peux nous montrer le code correspondant?

[nevroo]

je ne l'ai plus, je l'ai changé, mais j'ai toujours la meme erreur, je me suis dit qu'avec un compteur synchronizé, j'arriverai a definir si je dois mettre en pause le thread ou non, mais j'ai exactement la meme exception qui se lance :/

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
import java.util.concurrent.*;
 
public class Inf implements Runnable{
 
	protected  String text;
	protected String number;
	protected static int count=0;
 
	public Inf(String text){
		this.text  = text;
	}
 
	public void run(){
		while(true){
			synchronized(this){
				if(getCount() != 0){
					try{
						System.out.print("text is : "+text);
						System.out.println("     count : "+getCount());
						Thread.currentThread().wait();
					}catch(InterruptedException e){ System.out.println(e);	}
				}
				else{
					count++;
					displayPartOne();
					try{
						Thread.sleep(2000);
					}catch(InterruptedException e){ System.out.println(e);	}
					displayPartTwo();
					count--;
					notify();
				}
			}
		}
	}
 
 
	public synchronized int getCount(){	return count;	}
	public  void displayPartOne(){
		System.out.print(textPartOne());
	}
 
	public void displayPartTwo(){
		System.out.println(textPartTwo());
	}
	public String textPartOne(){
		String res="";
		for(int i=0;i < text.length()/2;i++){
			res += text.charAt(i);
		}
		return res;
	}
 
	public String textPartTwo(){
		String res="";
		for(int i=text.length()/2;i < text.length();i++){
			res += text.charAt(i);
		}
		return res;
	}
	// to help me for debuging	
	public void setNumber(String number){	this.number = number; }
 
	public String toString(){
		return "thread n  : "+number;
	}	
}

[®om]

Pourquoi tu fais

Code :

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

Thread.currentThread().wait();

Ca n'a pas de sens...

Fait:

Code :

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

wait();