java 多線程使用PipedOutStream和PipedInputStream

package test;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
public class PipeTest {
public static void main(String[] args) throws Exception {
PipedOutputStream pos = new PipedOutputStream();
PipedInputStream pis = new PipedInputStream();
//鏈接
pis.connect(pos);
//寫線程
InThread it = new InThread(pos,pis);
//讀線程
OutThread ot = new OutThread(pos,pis);
it.start();
ot.start();
Thread.sleep(1000);
}
}
class InThread extends Thread{
PipedOutputStream pos = null;
PipedInputStream pis = null ;
InThread(PipedOutputStream pos,PipedInputStream pis ){
this.pos = pos;
this.pis = pis;
}
public void run() {
try {
//寫入數(shù)據(jù)
byte[] b = new String("this is a test !").getBytes();
pos.write(b);
//關(guān)閉鏈接，此處必須關(guān)閉，不然會包異常  
pos.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
class OutThread extends Thread{
PipedInputStream pis = null ;
PipedOutputStream pos = null;
OutThread(PipedOutputStream pos,PipedInputStream pis){
this.pis = pis;
this.pos = pos;
}
public void run() {
//讀取數(shù)據(jù)
String m = "";
byte[] b = new byte[1024];
try {
int len ;
len = pis.read(b);
m = m+ new String(b);
while(len!=-1) {
len = pis.read(b); 
m = m+ new String(b);
}
//關(guān)閉資源
pis.close();
System.out.println(m);
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}