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 {//写入数据byte[] b = new String("this is a test !").getBytes();pos.write(b);//关闭链接，此处必须关闭，不然会包异常  pos.close();} catch (Exception e) {// TODO Auto-generated catch blocke.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() {//读取数据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);}//关闭资源pis.close();System.out.println(m);} catch (Exception e) {// TODO Auto-generated catch blocke.printStackTrace();}}}