PipedReader

Salut!
J'ai un problème pour faire parler 2 threads entre eux:
Je veux qu'ils s'échanges des String. J'utilise donc un PipedReader et
un PipedWriter connectés entre eux...
Par dessus un BufferedReader et un BufferedWriter pour utiliser des
String.
Seulement, je veux que chaque thread soit en permanence à l'écoute de
son BufferedReader.
J'ai donc mis le tout dans une boucle while car il me semblais que
BufferedReader.readLine() bloquait jusqu'à obtenir une ligne complète.
(Pour les tests j'utilise juste un seul thread.)
Mais j'obtiens:
java.io.IOException: Write end dead
at java.io.PipedReader.read(PipedReader.java:242)
at java.io.BufferedReader.fill(BufferedReader.java:136)
at java.io.BufferedReader.readLine(BufferedReader.java:299)
at java.io.BufferedReader.readLine(BufferedReader.java:362)
at Interpreter.run(Interpreter.java:29)

Voici mon source (je m'occuperai plus tard de la condition du while):
// Le thread:
public void run() {
input = new BufferedReader(reader);
output = new BufferedWriter(writer);
String str;
while (true) {
try {
str = input.readLine();
System.out.println("Ecrit");
output.write("repondu", 0, 7);
output.newLine();
output.flush();
} catch (IOException e) {
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}



/// le main():
Interpreter i = new Interpreter();

try {
PipedReader istream;
PipedWriter ostream;
BufferedReader input;
BufferedWriter output;
istream = new PipedReader();
input = new BufferedReader(istream);
ostream = new PipedWriter();
output = new BufferedWriter(ostream);

/* un tas de trucs pour connecter les PipedReader et writer..*/

i.start();

String s = "coucou";
output.write(s, 0, s.length());
output.newLine();
output.flush();
System.out.println(input.readLine());
} catch (IOException e) {
System.out.println(e.getMessage());
}
}


//////////////
PS: J'ai dut mettre les flush() sinon ça ne transmettait rien

Question: Comment faire pour que ça marche, c'est à dire pour que
readLine() attende qu'elle lise une ligne complète avant de retourner

Merci par avance.
Tuxfighter

Regarde la doc des PipedInput/OutputStream. Y'a rien dans celle des
PipedReader/Writer, mais il faut savoir qu'il ne faut pas créer un
Reader et un Writer connecté entre eux dans un même Thread, ça peut
créer un deadlock. J'espère que dans ton "un tas de trucs pour connecter
les PipedReader et writer", tu ne fais pas ça ?
Xav

tuxfighter wrote:

Salut!
J'ai un problème pour faire parler 2 threads entre eux:
Je veux qu'ils s'échanges des String. J'utilise donc un PipedReader et
un PipedWriter connectés entre eux...
Par dessus un BufferedReader et un BufferedWriter pour utiliser des
String.
Seulement, je veux que chaque thread soit en permanence à l'écoute de
son BufferedReader.
J'ai donc mis le tout dans une boucle while car il me semblais que
BufferedReader.readLine() bloquait jusqu'à obtenir une ligne complète.
(Pour les tests j'utilise juste un seul thread.)
Mais j'obtiens:
java.io.IOException: Write end dead
at java.io.PipedReader.read(PipedReader.java:242)
at java.io.BufferedReader.fill(BufferedReader.java:136)
at java.io.BufferedReader.readLine(BufferedReader.java:299)
at java.io.BufferedReader.readLine(BufferedReader.java:362)
at Interpreter.run(Interpreter.java:29)

Voici mon source (je m'occuperai plus tard de la condition du while):
// Le thread:
public void run() {
input = new BufferedReader(reader);
output = new BufferedWriter(writer);
String str;
while (true) {
try {
str = input.readLine();
System.out.println("Ecrit");
output.write("repondu", 0, 7);
output.newLine();
output.flush();
} catch (IOException e) {
System.out.println(e.getMessage());
e.printStackTrace();
}
}
}



/// le main():
Interpreter i = new Interpreter();

try {
PipedReader istream;
PipedWriter ostream;
BufferedReader input;
BufferedWriter output;
istream = new PipedReader();
input = new BufferedReader(istream);
ostream = new PipedWriter();
output = new BufferedWriter(ostream);

/* un tas de trucs pour connecter les PipedReader et writer..*/

i.start();

String s = "coucou";
output.write(s, 0, s.length());
output.newLine();
output.flush();
System.out.println(input.readLine());
} catch (IOException e) {
System.out.println(e.getMessage());
}
}


//////////////
PS: J'ai dut mettre les flush() sinon ça ne transmettait rien

Question: Comment faire pour que ça marche, c'est à dire pour que
readLine() attende qu'elle lise une ligne complète avant de retourner

Merci par avance.
Tuxfighter

--
"There is a theory which states that if ever anyone discovers exactly
what the Universe is for and why it is here, it will instantly disappear
and be replaced by something even more bizarre and inexplicable.
There is another theory which states that this has already happened."
-- Douglas Adams