Discussion :

[oraya]

Salut

Ça va faire plusieurs jours déjà que je m'acharne à vouloir faire marcher un pipe en Java. Mon erreur est peut être hyper simple, mais je ne veux pas de réponses du genre : "cherche sur google". Je suis loin d'être un débutant en Java, pourtant là, quelque chose m'échappe. Voila mon code (je vous passe les imports):

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
23
24
25
26
27
28
29
30
31
 
public class tst {
 
	public static void main(String[] args) {
 
		PipedInputStream pis = new PipedInputStream();
		PipedOutputStream pos = null;
		try {
			pos = new PipedOutputStream(pis);
		} catch (IOException e) {
			e.printStackTrace();
		}
 
		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
		OutputStreamWriter ow = new OutputStreamWriter(pos);
		String s = "";
 
		th T = new th(pis);
		T.start();
 
		try {
			while(true) {
				s = br.readLine();
				System.out.println(s);
				ow.write(s);
			}
		} catch (IOException e) {e.printStackTrace();}
 
	}
 
}

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
 
public class th extends Thread {
 
	private PipedInputStream pis;
 
	public th(PipedInputStream is) {
		this.pis = is;
	}
 
	public void run() {
 
		BufferedReader br = new BufferedReader(new InputStreamReader(this.pis));
 
		while(true)
			try {
				System.out.println(br.readLine());
			} catch (IOException e) {e.printStackTrace();}
	}
}

Le résultat attendu étant bien sur que le programme m'affiche deux fois ce que je saisi au clavier.

Voila voila
Et merci d'avance

[benratti]

Quelle est l'erreur que produit ton programme ou le résultat de son exécution?

[oraya]

Je n'ai justement pas de résultat de la part du thread.
J'entre quelque chose au clavier, donc le System.out.println() juste derrière m'affiche ce qu j'ai rentré (c'est juste histoire de débugger), mais à l'autre bout du pipe le thread n'affiche rien et donc n'arrive pas à lire dans le pipe :s

Mis à part ça, je n'ai aucune exception. Il semblerai que le thread soit encore en attente.

[bpy1401]

Bonjour orava

quand tu fait un tst en ligne 25

Code :

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

os.write(s);

remplace le par

Code :

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

os.write(s + "\n");

[oraya]

Ok j'essayerai et je vous tiens au courant. Mais sinon, pourquoi est-ce qu'un simple saut de ligne change les choses ?

[Jojo K-ri]

@"Je suis loin d'être un débutant en Java"
A cause du readLine()

[atha2]

Un petit coup de flush() sur ton buffer en sortie peut-être ??

[bpy1401]

Un petit coup de flush() sur ton buffer en sortie peut-être ??

J'y avais pensé, mais cela ne suffit pas

[oraya]

Bonjour orava

quand tu fait un tst en ligne 25

Code :

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

os.write(s);

remplace le par

Code :

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

os.write(s + "\n");

Non désolé ça ne marche pas mieux :s

[Mygalou]

Une solution à ton problème serait d'écrire directement dans ton PipedOutputStream.

De plus la création du PipedInputStream peut se faire directement dans lors de la création du Thread avec une connexion au PipedOutputStream créé.
Ce qui donnerait le code suivant :

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
23
24
25
26
27
28
29
30
 
public class tst {
 
	public static void main(String[] args) {
 
		PipedOutputStream pos = null;
		try {
			pos = new PipedOutputStream();
		} catch (IOException e) {
			e.printStackTrace();
		}
 
		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
		String s = "";
 
		th T = new th(new PipedInputStream(pos));
		T.start();
 
		try {
			while(true) {
				s = br.readLine();
                                s += "\n"
 				System.out.println(s);
			        pos.write(s.getBytes());
			}
		} catch (IOException e) {e.printStackTrace();}
 
	}
 
}

Il ne reste plus qu'a gérer la nullité du pos et le charset.

[-gma-]

En reprenant ton code d'origine, avec deux lignes en plus ça fonctionne :

Code :

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

1
2
3
ow.write(s);
ow.write('\n');
ow.flush();

[oraya]

Yeeees merci gma ^^
C'est quoi en fait flush() ?

[thelvin]

Voici la JavaDoc de Writer.flush(). Elle est carrément semblable à OutputStream.flush(), et de manière générale respecte Flushable.flush().

La JavaDoc est assez claire. flush() indique que si, par le plus grand des hasard, le Writer a gardé des caractères dans un buffer et ne cherche pas encore à les écrire/transmettre, alors il doit vider maintenant son buffer en les écrivant/transmettant.

Un BufferedWriter, par exemple, fait cela exprès justement pour transmettre les caractères par grandes quantités, plutôt que de faire des transmissions coûteuses, un caractère à la fois. Mais si, à un moment, on veut vraiment que ce qu'on vient d'écrire soit transmis tout de suite, flush() lui ordonne de le faire.

Un PipedOutputStream fonctionne pareil : pour que ça marche, il y a un buffer partagé entre le PipedOutputStream et le PipedInputStream. Comme l'indique la JavaDoc de PipedOutputStream.flush(), l'InputStream n'essaie pas de consommer tout de suite dès qu'on lui insère dans le buffer. Ce ne serait pas efficace. Il attend que le buffer soit plein, ou bien que le PipedOutputStream soit fermé, pour tout lire d'un coup. Un flush() du côté du OutputStream lui ordonne de lire le buffer immédiatement.
Sur le principe c'est une bonne idée, mais dans ton cas d'utilisation c'est perturbant, parce qu'il faut remplir le buffer avant de voir les effets du pipe. Et il fait quand même 1ko.

[oraya]

Ok ok
Et bien merci pour cette explication ^^