Discussion :

[FidoDido®]

Hello, je cherche à utiliser les ReentrantLock pour un problème simple de producteur/consommateurs.
Mais le programme a un comportement que je n'arrive pas à comprendre...

Je joins les fichiers .java correspondants

En gros, j'utilise un producteur, plusieurs consommateurs et entre les deux un objet SharedData qui fait la liaison et sur lequel se portent les problèmes de concurrence.
Le SharedData a un attribut data qui est la donnée partagée et les méthodes de get/set que voici :

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
	public int getData(String name) throws InterruptedException{
		locker.lock();
		try {			
			if(ontLu >= nbConso) {
				toutLu.signal();
			}
			else {
				produit.signal();
			}
 
			/**
                         * tant que pas de production on attend
                         */
			produit.await();
			ontLu++;
		} 
		finally {
			locker.unlock();
		}	
 
		return data;
	}

et

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 void setData(int n) throws InterruptedException {
		locker.lock();
		try {
			/**
                         * tant que tout n'a pas été lu, on attend
                         */
			toutLu.await();
 
			data = n;
			ontLu = 0;
 
			/**
                         * on envoie le signal indiquant qu'une nouvelle valeur a été créée
                         * à tous les consommateurs
                         */
			produit.signal();
		} 
		finally {
			locker.unlock();
		}
	}

où l'entier ontLu représente le nombre de consommateurs ayant lu le data à l'instant présent et nbConso est le nombre de consommateurs reliés au SharedData.

Donc si je fais un exemple simple (le producteur envoie un entier qu'il incrémente à chaque fois), au bout d'un certain temps je rentre en interblocage alors que ça marchait avant.

Et je ne comprends pas d'où ça vient...

Si quelqu'un pouvait m'aider ce serait cool.

Merci

[professeur shadoko]

euh, par hasard, tes variables toutLu et nbConso n'auraient pas besoin d'être volatile ?

[FidoDido®]

A priori la variable nbConso n'a pas besoin d'être volatile puisqu'elle ne varie pas au cours des accès concurrentiels, mais au moment de la création du SharedData et de l'ajout d'un consommateur supplémentaire à celui-ci.

Pour ce qui est de ontLu, j'ai fait la modification, mais cela ne résoud pas mon problème. Au bout d'un certain temps (variable) le programme s'arrête.

[FidoDido®]

Tjs pas trouvé...
Personne ne voit d'où ça pourrait venir ?

[®om]

Avant de faire un await() il faut faire un test (on n'a pas toujours besoin d'attendre).
Et ce test doit être dans un while et pas dans un if...
(cf http://rom.developpez.com/java-synchronisation )

[FidoDido®]

OK mais le truc c que je vois pas quelle condition je dois vérifier pour pouvoir faire un await() dans ce cas...
Ou alors faudrait que je créé une liste des consommateurs dans le SharedData qui indique si le consommateur courant a déjà lu ou non ?