Discussion :

[powel]

Bonsoir à tous,

prenons cet extrait de début de code :

Code :

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

1
2
3
 
final Socket socket = new Socket (hostName, port);
is = socket.getInputStream ();

j'ai besoin qu'au moins deux threads traitent les infos du flux "is" genre :

Code :

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

1
2
3
4
5
6
final Scanner scan = new Scanner(is, "UTF-8");
 
				while (scan.hasNextLine()) {
...
 
}

chaque thread prend ce qu'il a besoin comme infos et effectue des actions en conséquence.

Problème ; lorsque l'un thread lit une ligne d'is en quelque sortes il l'enlève à l'autre thread qui lit la suivante et qui a à son tour l'enlève à l'autre.

Or j'aimerai que tous les threads aient à disposition toutes les infos d ' "is".

Donc est-il possible de dupliquer le flux "is" afin que chaque thread possède le même flux ...

Pour le moment j'ai du me faire un distributeur du flux avec des pools :

Code :

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

1
2
3
4
5
6
7
 
while (scan.hasNextLine()) {
					final String line = scan.nextLine();
					for (int i = 0; i < listeners.size(); i++) {
						listeners.get(i).queue.add(line);
					}
}

Dans ce code, il y a autant de listeners que de thread ce qui me permet d'imiter une duplication des flux.


Mais est-ce une méthode normale je vois que Java ne propose rien quand à une duplication du flux d'entrée ou j'ai mal regardé ?

Merci.

[thelvin]

Hello,

Disons qu'il est surtout extrêmement bizarre d'avoir ce besoin-là.

Si l'un de tes threads s'occupe de consommer les données, pourquoi diable d'autres threads devraient-ils s'en occuper ? Un prédécoupage en messages individuels, qui peuvent être ensuite envoyés à tous les observateurs, ça peut encore se comprendre. Mais l'InputStream directement.... Pourquoi ?

A ma connaissance Java ne propose pas de duplication de flux, mais il existe des bibliothèques tierces qui le font. Probablement pas pour les gens qui penseraient à une chose pareille, toutefois.

[powel]

Bon voilà qui répond à ma question, ma solution surprend donc.

L'idée est qu'une fois connecté à un hôte, je puisse lancer toutes sortes de listener de courtes ou longues durées, par exemple pour récupérer ponctuellement des infos après une demande, ou un listener permanent qui sert à répondre présent à l'hôte.

Chaque listener ne prend dont ce qu'il a besoin et sans enlever à son voisin ce que lui a besoin.

Sachant que l'hôte n'a pas d'ordre de règles quand à l'envoie des messages ;
- il peut très bien envoyer une longue liste durant jusqu'à 1 minute
- pendant ce temps il demande si le client est toujours présent (réponse à un ping, il entre coupe donc sa liste)
- et dans le même temps m'avertir par petites touches d'événements ponctuels

Imaginons donc trois listener, chaqu'un traite son taf, s'éteind lorsqu'il a finit. etc ...

---

ma soluce marche mais c'est vrai que ça fait un moment que je trouve bizarre de l'avoir fait artisanalement.

[thelvin]

Disons que ça paraît plus logique de s'abstraire des InputStreams et de raisonner par messages, avec les listeners, comme tu as déjà.

[powel]

OK

Entre-temps j'ai fait un truc rapide.

Donc à quoi peut me servir de dupliquer un flux d'entrée ? pour éviter ça ...

[thelvin]

Oui mais c'est ce que je viens de dire en fait. Ne duplique pas le flux d'entrée.
Lis les lignes du flux d'entrée, et envoie-les toutes aux concernés.