Discussion :

[fantomasmusic]

Bonjour,

Je suis en train de créer un "mini" serveur NIO. Je voudrais effectuer les traitements de lecture dans un autre Thread.
Et j'ai une humble question !

Le serveur lit en boucle les données dans le selector

Code :

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

1
2
3
4
5
6
7
8
9
10
 
While(true)
..blabla //on parcours les clés dans le selector
 
if(k.isAcceptable()){
  blabla...
if(k.isReadable()){
   // si y'a une clé "lisible" alors il ajoute la clé dans une LinkedList (que je nomme queue)
  queue.add(k);
}

Et j'ai un thread qui lit en boucle ma queue.

Code :

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

1
2
3
4
5
6
while(true)
   if(queue.size()>=1){
        SelectionKey k = queue.remove();
        readData(k);
   }
}

La fonction readData(k); lit le contenu de la clé et fait le traitement correspondant.

Problème:

Le problème, c'est qu'entre le moment où j'ajoute la clé(SelectionKey) dans la queue (linkedList) et que la clé soit effectivement lue et traitée par le thread qui lit la queue.... la clé a été inséré plein de fois dans la queue...
Donc, je me suis dis, "une fois que je lis la clé, je peux faire un k.cancel()..." mais c pas une bonne solution non plus...
La conclusion est que, ce que je veux faire ne peux pas se faire en stockant les clés dans une queue.

Ma conclusion:

En faites, quand je lis les clés, il faut que je lise le contenu et c'est ce le contenu que je met dans la queue (LinketList) et ensuite mon thread "traitement" réalise le traitement correspondant.

Est-ce que ca vous parait correcte ce que je dis?




Merci de m'avoir lu,
Bien cordialement.

Cécilia.

[jowo]

Bonjour,


Une solution possible est:

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
 
while (selector.select() > 0) {
    // Récupère les clés sélectionnées dans une collection
    Set keys = selector.selectedKeys();
    // Parcourir les clés selectionnées
    Iterator i = keys.iterator();
    while (i.hasNext()) {
        // On isole la clé courante
        SelectionKey k = (SelectionKey) i.next();
        // Retire la clé courante de la collection
        i.remove();
        if (k.isAcceptable()) {
           blabla...
         }  
         if (k.isReadable()) {
            // si y'a une clé "lisible" alors il ajoute la clé dans une LinkedList (que je nomme queue)
           queue.add(k);
          }
        .....

[fantomasmusic]

Merci, pour info, j'avais déjà mis le remove().

En faites ce que je voulais faire ne pouvait pas marcher.
Désormais, je lis le contenu de la clé, et je récupère la clé "key"
Je créais un objet new Requete(data, key) et j'ajoute dans la queue ma requete.
Et ca marche sans soucis...

Pour des soucis de performance je voulais éviter de faire lire le contenu de la clé (quand isReadable() == true) sur le serveur, mais finalement, le serveur lit le contenu, il ne fait que ça.
D'autres threads s'occupent que du traitement (base de données, réponse aux autres clients etc.., renvoie des données, consulation de tables, etc..)

Bref, de toute façon j'avais pas le choix

Merci en tous ça

[Rayndell]

Ne serait-il pas plus simple, avant d'effectuer une insertion dans queue, de vérifier si cette clé n'est pas déjà dans queue ? Cela éviterait les doublons.