Discussion :

[riadhhwajdii]

Salut
Je suis entrain de developper une application desktop java multi-thread.
j'ai une table utilisé pour stocké un valeur utilisé comme séquences.

Code :

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

1
2
3
4
5
6
 
 CREATE TABLE "MESSAGE_SEQUENCE" 
   (	
	"VALEUR_SEQ" NUMBER(20,0), 
	"BLOCAGE" NUMBER(1,0) DEFAULT 0
   ) ;

• La colonne VALEUR_SEQ contient la valeur de la séquence

• La colonne BLOCAGE contient 0 ou 1,le premier thread qui execute une procedure met la valeur à 1 pour empêcher les autre threads d'accéder simultanément à la table.une fois il a recupérer la valeur VALEUR_SEQ , il augmente VALEUR_SEQ et rend BLOCAGE à 0.

cette table est utilisé par plusieurs procédures stockés utilisé par mon application:voici le code qui permet de recupérer la valeur VALEUR_SEQ:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
 
LOOP
	BEGIN
            SELECT BLOCAGE INTO BLOCAGE FROM MESSAGE_SEQ  FOR UPDATE of BLOCAGE;
	   IF BLOCAGE =0 THEN
	   	UPDATE  MESSAGE_SEQ SET BLOCAGE= 1 ;
	   	SELECT VALEUR_SEQ + 1 INTO V_COD_MES_INT FROM MESSAGE_SEQ ;
	  	UPDATE  MESSAGE_SEQ SET VALEUR_SEQ= VALEUR_SEQ + 1; 
	  	UPDATE  MESSAGE_SEQ SET BLOCAGE= 0 ;
       		EXIT;
	   END if;

D'abord tout marche bien mais aprés repéter les tests plusieurs fois,une erreur apparaît; en fait ,parfois la valeur de BLOCAGE se bloque à la valeur 1 empêchant ainsi tous les threads d'accéder au code!
pourquoi cette erreur est comment résoudre ce probléme?

[Invité]

As-tu impérativement besoin d'avoir une séquence avec une suite de nombre concomitant (sans trou dans la suite)? Sinon utilise une séquence Oracle, ça t'évitera de réinventer la roue.
http://fadace.developpez.com/oracle/sequences/

[riadhhwajdii]

As-tu impérativement besoin d'avoir une séquence avec une suite de nombre concomitant (sans trou dans la suite)? Sinon utilise une séquence Oracle, ça t'évitera de réinventer la roue.
http://fadace.developpez.com/oracle/sequences/

Merci pour la réponse.
Mais mon problème est que je doit utilisé la base donnée existante.
Je doit résoudre le problème avec la table MESSAGE_SEQ.
Je n'ai pas compris pourquoi ces erreurs de blocage,non féquentes, se posent,est ce qu'il y a une erreur dans mon code ou est ce que il y une amélioration que je puisse faire?

[pachot]

Bonjour,

BLOCAGE ne sert à rien, le verrou sur l'enregistrement suffit à sérialiser l'accès à MESSAGE_SEQ.
Tout ce code pourrait être remplacé par:

Code :

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

UPDATE  MESSAGE_SEQ SET VALEUR_SEQ= VALEUR_SEQ + 1 RETURNING VALEUR_SEQ into V_COD_MES_INT;

parfois la valeur de BLOCAGE se bloque à la valeur 1

Comment as-tu pu voir celà ? la valeur 1 n'est jamais commitée ?

D'ailleurs, quand est-ce que se fait le commit ? Si c'est à la fin, alors à quoi sert de faire du multi-thread si tous les threads sont sérialisés sur une seule ressource ?

Et la seule solution pour avoir un numéro de sequence, avec une concurrence d'accès, c'est une sequence.

Je doit résoudre le problème avec la table MESSAGE_SEQ.

Pourquoi ? C'est pour un pari ? alors:

Code :

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

SELECT sequence.NEXTVAL from MESSAGE_SEQ;

Cordialement,
Franck.

[riadhhwajdii]

Bonjour,

Comment as-tu pu voir celà ? la valeur 1 n'est jamais commitée ?

Désolé pour oubliez le commit, c'était une simple faute de copiage:

Code :

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

UPDATE  MESSAGE_SEQ SET BLOCAGE= 0 ;commit;

à quoi sert de faire du multi-thread si tous les threads sont sérialisés sur une seule ressource ?

Pour bien clarifier les choses,mon application reçoit plusieurs messages à traiter indépendamment,chaque thread traite un message mais au moment de persistance,chaque thread appele une procedure stocké qui contient le code plsql qui permet de récupérer la valeur de la colonne VALEUR_SEQ(cette valeur servira comme une clé primaire pour les messages).

Pourquoi ? C'est pour un pari ? alors:

En fait,il ya d'autre modules qui utilisent la table MESSAGE_SEQ ,c'est pourqu'oi j'ai besoin de travailler avec cette table