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()

[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.