对PipedOutputStream/PipedInputStream类的应用

import java.io.*;

public class Sender extends Thread {
private PipedOutputStream out = new PipedOutputStream();

public PipedOutputStream getOutputStream() {
return out;
}

public void run() {
String strInfo = new String("hello,receiver!");
try {
out.write(strInfo.getBytes());
out.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}

import java.io.*;

public class Receiver extends Thread {
private PipedInputStream in = new PipedInputStream();

public PipedInputStream getInputStream() {
return in;
}

public void run() {
byte[] buf = new byte[1024];
try {
int len = in.read(buf);
System.out.println("the folloeing message comes from sender\n"
+ new String(buf, 0, len));
} catch (Exception e) {
e.printStackTrace();
}
}
}

import java.io.*;

public class PipedStreamTest {
public static void main(String[] args) {
// TODO Auto-generated method stub
Sender t1 = new Sender();
Receiver t2 = new Receiver();
PipedOutputStream out = t1.getOutputStream();
PipedInputStream in = t2.getInputStream();
try {
out.connect(in); // 或者in.connect(out);是一样的
} catch (Exception e) {
e.printStackTrace();
}
t1.start();
t2.start();
}
}