|
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.PipedReader;
import java.io.PipedWriter;
import java.io.Reader;
import java.io.Writer;
public class PipedCharacters extends Object {
public static void writeStuff(Writer rawOut) {
try {
BufferedWriter out = new BufferedWriter(rawOut);
String[][] line = { { "Java", "Source", "and", "Support." }};
for (int i = 0; i < line.length; i++) {
String[] word = line[i];
for (int j = 0; j < word.length; j++) {
out.write(word[j]);
}
out.newLine();
}
out.flush();
out.close();
} catch (IOException x) {
x.printStackTrace();
}
}
public static void readStuff(Reader rawIn) {
try {
BufferedReader in = new BufferedReader(rawIn);
String line;
while ((line = in.readLine()) != null) {
System.out.println("read line: " + line);
}
System.out.println("Read all data from the pipe");
} catch (IOException x) {
x.printStackTrace();
}
}
public static void main(String[] args) {
try {
final PipedWriter out = new PipedWriter();
final PipedReader in = new PipedReader(out);
Runnable runA = new Runnable() {
public void run() {
writeStuff(out);
}
};
Thread threadA = new Thread(runA, "threadA");
threadA.start();
Runnable runB = new Runnable() {
public void run() {
readStuff(in);
}
};
Thread threadB = new Thread(runB, "threadB");
threadB.start();
} catch (IOException x) {
x.printStackTrace();
}
}
}
|
