Discussion :

[wazer]

Bonjour à tous,

Je voudrais simuler en java un ordonneonceur pour la réservation de ressources.

Pour cela j'ai besoin de bloquer une demande de réservation, en attendanbt que la ressource soit libéré.

Existe il une façon d'attaquer ce probléme.
J'ai essaué avec l'exemple consommateur-producteur mais ça ne fonctionnait pas ?


Merci

[iohack]

Regarde du côté de la classe Thread et du mot-clef java "synchronized" ?

[wazer]

Regarde du côté de la classe Thread et du mot-clef java "synchronized" ?

l'exemple producteur cosommateur se base sur cela;
seulement ceci ne m'a pas résolu le probléme.

[iohack]

Je ne connais l'exemple dont tu parles mais si tu mets une synchronization sur ton objet ressource lorsque tu t'en sert et une même synchronization lors de la réservation, cela devrait répondre à ta question:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
 
public void traitementRessource(Ressource r){
   synchronized(r){
        // Traitement de la ressource
   }
}
 
public void reservation(Ressource r){
   synchronized(r){
        // Effectue la reservation uniquement lorsque la ressource sera liberee ( car au mot clef synchronized )
   }
}

[adiGuba]

Salut,

l'exemple producteur cosommateur se base sur cela;
seulement ceci ne m'a pas résolu le probléme.

C'est à dire ??? Quel est le problème ???

a++

[wazer]

Salut,

l'exemple producteur cosommateur se base sur cela;
seulement ceci ne m'a pas résolu le probléme.

C'est à dire ??? Quel est le problème ???

a++

Voici le probléme;

Supposons que j'ai 2 ressources disponibles; s1 et s2. (dans mon cas il s'agit de n ressources; valeur inconnu).

le client A reserve et utilise la resoource s1.
le client B reserve et utilise la resoource s2.


un client C veut reserver une ressourse, il lance une demande de reservation. Puisque tous les ressources sont reserves, j'aimerais mettre en instance (en attente ) sa demande sans que ceci bloque l'execution de l'application

quand le clienr A libére s1; je voudrais que le programme va reserver s1 pour le client C.

Quand j'ai utilisé les methodes wait() et notifyAll(), mon application se bloque des que le client C fait une demande de reservation de ressource.


Merci pour votre aide

[adiGuba]

Il vaut mieux utiliser synchronized que des wait() et notifyAll(), c'est plus simple à gérer.

Quand j'ai utilisé les methodes wait() et notifyAll(), mon application se bloque des que le client C fait une demande de reservation de ressource.

Tu est bien en environnement multithread au moins ???

a++

[wazer]

Tu est bien en environnement multithread au moins ???

Oui bien sûr,

Mais je me demande également si il n'y aps une autre façon pour attaque le probléme ?



Maerci

[BugFactory]

Je créerai une classe de pool de ressource. Celle ci contiendrait une méthode réserver qui prend en paramêtre un client et renvoie une ressource libre si il y en a une, et null si il n'y en a pas. Si il n'y a pas de ressource, le client passé en paramêtre est ajouté à une file "attente". Quand une ressource est libérée, grâce à une méthode libérer du pool, celui-ci vérifie si il y a un client dans attente. Si c'est le cas, il invoque une méthode voiciLaRessource du client qui prend en paramètre la ressource libérée. Le pool est unique, son thread est indépendant, ses méthode réserver et libérer sont synchronized. Le client doir susprendre son thread lui-même quand sa demande de réservation reçoit null.

[let_me_in]

tu as une classe java.util.concurrent.Semaphore; (1.5 seulement).

-tu cree un semaphore S initialise a 0.

-un semaphore mutex d'esclision mutuelle (initalise a 1);
-une variable entiere nbResourceDispo intialisee a 2.

et voila l'algo:

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
 
P(mutex); // mutex.acquire() en java
si (nbRessourceDispo==0){
     V(mutex);
     P(S);
     }
     else{
            nbRessourceDispo--;
            V(mutex);
            }
<Section Critique>
 
P(mutex)
si (S.hasQueuedThreads()) V(S);
else nbRessourceDispo++;