Problème avec la synchronization de 2 threads

**Frac10** · 15/11/2006, 19h25

Bonjour tout le monde !

Bon alors le fait est que j'ai essayé de comprendre la synchronization via les tutoriels présents sur le site, mais il reste un petit problème pour mon application.

L'application va dans un premier temps télécharger un fichier .xls sur le net et dans un deuxième temps l'ouvrir. Donc il faut que le premier thread soit terminé quand le deuxième commence...

Donc j'ai essayé de mettre des synchronized, des wait() et des notify(), mais il reste toujours un problème.

En effet, le thread qui télécharge le fichier utilise une classe à part qui affiche une barre de progression pour voir le temps que çà prend. Et le problème est que lorsque les threads sont synchronizés (de la mauvaise manière je pense), la barre de progression ne s'affiche plus et çà bloque la fenêtre. Alors que quand ils ne sont pas synchronizés, elle s'affiche et se rempli nickel.

Je mets le code simplifié de l'application qui lance les 2 threads:

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
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import javax.swing.*;
import jxl.*;
 
public class GetFile extends JFrame {
 
	public GetFile() {
		setSize(100, 100);
		Dimension screen = Toolkit.getDefaultToolkit().getScreenSize();
		setLocation((screen.width - this.getSize().width)/2,
		 (screen.height - this.getSize().height)/2);
		setContentPane(getJDesktopPane());
		setVisible(true);
	}
 
	private JDesktopPane getJDesktopPane() {
		JDesktopPane jdp = new JDesktopPane();
		JPanel jp = new JPanel();
		jp.setSize(100, 100);
		jp.setLocation(new java.awt.Point(1,1));
 
		JButton jb = new JButton("Go !");
 
		jp.add(jb, BorderLayout.CENTER);
 
		jb.addActionListener(new ActionListener() {
			public void actionPerformed(ActionEvent e) {
				go1();
				go2();
			}
		});
 
		jdp.add(jp);
		jdp.setVisible(true);
		jdp.updateUI();
 
		return jdp;
	}
 
	synchronized private void go1() {
		HTTPGetFile gf = new HTTPGetFile("http://otarie10.free.fr/datas.xls");
		notify();
	}
 
	synchronized private void go2() {
		try {
			wait();
			Workbook workbook = Workbook.getWorkbook(new File("datas.xls"));
			Sheet sheet = workbook.getSheet(0);
 
			workbook.close();
		} catch (Exception e) {
			System.out.println("Impossible d'ouvrir le fichier .xls");
			System.out.println(e);
		}
	}
 
	public static void main(String[] args) throws IOException {
		JFrame.setDefaultLookAndFeelDecorated(true);
		new GetFile();
	}
}

La classe HTTPGetFile (récupérée sur un autre site) sert à télécharger le fichier passé en paramètre et à afficher la barre de progression.

Voilà, je pense que çà vient du fait que je n'ai rien compris à la synchronization, mais si quelqu'un pouvait m'éclairer ce serait sympa...

Merci d'avance !!!

**lxegre** · 16/11/2006, 00h37

Salut! Bon je ne pense pas être un pro de la synchro sous Java mais une chose est sûre j'ai gagné beacoup de temps de debug depuis que j'ai découvert la classe SwingWorker. C'est une classe utilitaire qui permet de gérer facilement les threads au sein d'une application Swing (librarie telechargeable ici). Cette classe fera d'ailleurs partie de javax dans Java SE 6.

Je te conseille donc de faire usage de cette librairie pour toutes les actions lourdes qui pourraient figer ton interface.

Voila plus bas un exemple d'usage pour le code que tu as envoyé. J'ai essayé de modifier un minimum ton code. J'ai remplacé tes fonctions "lourdes" par des sleep pour la demonstration.

Pour revenir a ton probleme de base, je ne vois pas pourquoi tu veux faire deux threads dans la mesure ou la premiere dois terminer avant que la deuxieme puisse commencer ?! Une simple thread qui lance ton telechargement de XLS et puis l'ouverture du fichier devrait suffir. C'est ce que j'ai fait dans l'exemple plus bas.

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
 
import java.awt.*;
import java.awt.event.*;
import java.io.*;
 
import javax.swing.*;
 
import org.jdesktop.swingworker.SwingWorker;
 
 
public class GetFile extends JFrame {
 
	private JButton jbGo;
 
	private JTextArea jtaLog;
 
	class LoadExcelTask extends SwingWorker<Void, Void> {
 
		@Override
		public Void doInBackground() {
			go1();
			go2();
			return null;
		}
 
 
		@Override
		public void done() {
			jtaLog.append("Fini !\n");
			jbGo.setEnabled(true);
		}
	}
 
	public GetFile() {
		setSize(300, 200);
		Dimension screen = Toolkit.getDefaultToolkit().getScreenSize();
		setLocation((screen.width - this.getSize().width) / 2,
				(screen.height - this.getSize().height) / 2);
		setContentPane(getJDesktopPane());
		setVisible(true);
	}
 
	private JDesktopPane getJDesktopPane() {
		final JDesktopPane jdp = new JDesktopPane();
		JPanel jp = new JPanel();
		jp.setSize(300, 200);
		jp.setLocation(new java.awt.Point(1, 1));
		jbGo = new JButton("Go !");
		jp.add(jbGo, BorderLayout.CENTER);
 
		jtaLog = new JTextArea(5, 20);
		jtaLog.setMargin(new Insets(5, 5, 5, 5));
		jtaLog.setEditable(false);
 
		jp.add(new JScrollPane(jtaLog), BorderLayout.SOUTH);
		jp.setBorder(BorderFactory.createEmptyBorder(20, 20, 20, 20));
 
 
		jbGo.addActionListener(new ActionListener() {
			public void actionPerformed(ActionEvent e) {
				jbGo.setEnabled(false);
				new LoadExcelTask().execute();
			}
		});
		jdp.add(jp);
		jdp.setVisible(true);
		jdp.updateUI();
		return jdp;
	}
 
	private void go1() {
 
		try {
			jtaLog.append(String.format("Téléchargement du fichier XLS\n"));
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
 
	private void go2() {
		try {
			jtaLog.append(String.format("Ouverture du fichier XLS\n"));
			Thread.sleep(1000);
		} catch (InterruptedException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
 
	}
 
	public static void main(String[] args) throws IOException {
		JFrame.setDefaultLookAndFeelDecorated(true);
		new GetFile();
	}
}

Sinon en deux mots, le SwingWorker comment ca marche : tu implementes une classe de type SwingWorker. La methode doInBackground() doit etre implementée. C'est elle qui définie le travail lourd à effectuer. On peut optionellement implementer une methode done() qui sera lancée apres l'execution de doInBackground(). Il existe aussi des methode d'interruption etc... La classe est definie de maniere generique : deux types fournis en parametres mais dans ton cas ne t'en soucis pas et laisse <void, void> comme dans l'exemple.

Voila j'espere que tout ca va t'aider...

Bon code,
lxegre

**woodwai** · 16/11/2006, 13h08

Il ne faut pas confondre, quand une methode est synchronized, celà ne veut pas dire qu'elle est synchronisé, mais celà veut dire qu'un seul thread peut passer dedans en même temps!

Peut être que ton problème se situe donc au niveau de l'utilisation de méthode synchronized, en effet, si ce que tu veut c'est juste attendre que quelque chose soit fait avant de faire autre chose, alors le mot clé synchronized ne te sert à rien, un wait et un notify suffisent.

**®om** · 16/11/2006, 13h12

Envoyé par woodwai

un wait et un notify suffisent.

En faisant bien attention que le wait() ait lieu avant le notify()...
(ou alors utiliser des sémaphores, c'est géré automatiquement le notify avant le wait (v avant le p))

**Frac10** · 17/11/2006, 13h05

Tout d'abord, un grand merci à tous les 3 pour vous pencher sur mon problème !

Ixegre, j'ai essayé avec le SwingWorker que tu m'as proposé, mais il lance les 2 threads ("go1" et "go2") à la suite sans attendre la fin du premier : je ne comprends pas pourquoi...

Sinon pour woodwai et ®om, c'était bien une histoire de notify() et de wait(). Sauf que j'avais une erreur :

Code :

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

java.lang.IllegalMonitorStateException: current thread not owner

Donc j'ai mis un synchronized devant les 2 notifyAll() et wait() et çà marche (par contre, je ne vois toujours pas pourquoi, mais bon faudra que je me penche sur ces histoires de threads un jour ou l'autre)...

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
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
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import javax.swing.*;
import jxl.*;
 
public class GetFile extends JFrame {
 
	private JButton jbGo;
 
	public GetFile() {
		setSize(100, 100);
		Dimension screen = Toolkit.getDefaultToolkit().getScreenSize();
		setLocation((screen.width - this.getSize().width)/2,
		 (screen.height - this.getSize().height)/2);
		setContentPane(getJDesktopPane());
		setVisible(true);
	}
 
	private JDesktopPane getJDesktopPane() {
		JDesktopPane jdp = new JDesktopPane();
		JPanel jp = new JPanel();
		jp.setSize(100, 100);
		jp.setLocation(new java.awt.Point(1,1));
 
		jbGo = new JButton("Go !");
 
		jp.add(jbGo, BorderLayout.CENTER);
 
		jbGo.addActionListener(new ActionListener() {
			public void actionPerformed(ActionEvent e) {
				jbGo.setEnabled(false);
				lanceThread();
			}
		});
 
		jdp.add(jp);
		jdp.setVisible(true);
		jdp.updateUI();
 
		return jdp;
	}
 
	private void go1() {
		HTTPGetFile gf = new HTTPGetFile("http://MonFichierXLS.xls");
		synchronized (this) {
			this.notifyAll();
		}
	}
 
	private void go2() {
		try {
			synchronized (this) {
				wait();
			}
			Workbook workbook = Workbook.getWorkbook(new File("datas.xls"));
			Sheet sheet = workbook.getSheet(0);
 
			workbook.close();
			System.out.println("C'est bon !!!");
		} catch (Exception e) {
			System.out.println("Impossible d'ouvrir le fichier .xls");
			System.out.println(e);
		}
	}
 
	public void lanceThread() {
		Thread t = new Thread() {
			public void run() {
				try {
					go1();
					go2();
				} catch (Exception ex) {
					System.out.println("erreur thread : " + ex);
				}
			}
		};
		t.start();
	}
 
	public static void main(String[] args) throws IOException {
		JFrame.setDefaultLookAndFeelDecorated(true);
		new GetFile();
	}
}

Merci encore à tous !!!

**adiGuba** · 17/11/2006, 13h12

Salut,

Envoyé par Frac10

Ixegre, j'ai essayé avec le SwingWorker que tu m'as proposé, mais il lance les 2 threads ("go1" et "go2") à la suite sans attendre la fin du premier : je ne comprends pas pourquoi...

Parce que SwingWorker sert à cela !! Mais dans ton cas ce n'est pas un vraiment un problème de synchronisation : tes deux traitements sont simplement exécuter l'un à la suite de l'autre et tes notify()/wait() sont inutile :

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
	private void go1() {
		HTTPGetFile gf = new HTTPGetFile("http://MonFichierXLS.xls");
	}
 
	private void go2() {
		try {
			Workbook workbook = Workbook.getWorkbook(new File("datas.xls"));
			Sheet sheet = workbook.getSheet(0);
 
			workbook.close();
			System.out.println("C'est bon !!!");
		} catch (Exception e) {
			System.out.println("Impossible d'ouvrir le fichier .xls");
			System.out.println(e);
		}
	}

Envoyé par Frac10

Donc j'ai mis un synchronized devant les 2 notifyAll() et wait() et çà marche (par contre, je ne vois toujours pas pourquoi, mais bon faudra que je me penche sur ces histoires de threads un jour ou l'autre)...

Parce que notify() et wait() permette des synchronisation entre différents thread, et qu'il doivent donc utiliser un verrou unique et donc des bloc synchronized... C'est indiqué dans la documentation de ces méthodes

a++

**®om** · 18/11/2006, 11h21

Envoyé par Frac10

L'application va dans un premier temps télécharger un fichier .xls sur le net et dans un deuxième temps l'ouvrir. Donc il faut que le premier thread soit terminé quand le deuxième commence...

Une question bête, pourquoi tu veux absolument faire le téléchargement et l'ouverture dans 2 threads différents?

**Frac10** · 18/11/2006, 11h43

Heu t'en fais pas c'est pas une question bête, loin de là !

Au départ je ne voulais même pas utiliser de threads et seulement lancer les appels à mes procèdures à la suite, go1() puis go2() (dans le fichier GetFile.java).
Cela marche très bien puisque go2() attendait la fin de go1() pour se lancer.

Sauf que j'ai voulu rajouter une barre de progression au traitement de go1() (c'est-à-dire dans le fichier qui gère le téléchargement HTTPGetFile.java) pour que çà soit plus convivial. Et ce rajout je l'ai donc fait au sein d'un thread dans le programme de téléchargement (si je ne le met pas dans un thread, l'interface de progression ne s'affiche pas...

).

Et donc en rajoutant ce thread dans HTTPGetFile le processus go2() n'atends plus la fin du processus go1() dans GetFile...
Et là, je dois avouer que je ne comprends rien de rien...

Problème avec la synchronization de 2 threads

Concurrence et multi-thread Java

Vue hybride

Discussions similaires

Partager

Partager