[零基础学JAVA]Java SE应用部分-29.Java IO操作（03）

import java.io.*;    
//设置两个线程，一个发送另一个接收    
class Send  implements Runnable{    
         private PipedOutputStream out =  null;    
         //在构造方法中实例化此对象    
         public Send(){    
                 this.out =  new PipedOutputStream();    
        }    
         public  void run(){    
                 //启动线程，启动线程时直接发送    
                String str =  "Hello World~~~";    
                 try{    
                         this.out.write(str.getBytes());    
                } catch (Exception e){}    
        }    
         //必须把管道输出流返回去    
         public PipedOutputStream getOut(){    
                 return  this.out;    
        }    
}    
class Receive  implements Runnable{    
         private PipedInputStream input =  null;    
         public Receive(){    
                 this.input =  new PipedInputStream();    
        }    
         public  void run(){    
                 //启动线程，接收内容    
                 byte b[] =  new  byte[1024];    
                 int len = 0;    
                 try{    
                        len =  this.input.read(b);    
                         this.input.close();    
                        System.out.println( new String(b,0,len));    
                } catch (Exception e){}    
        }    
         public PipedInputStream getInput(){    
                 return  this.input;    
        }    
}    
public  class IODemo01{    
         public  static  void main(String args[]){    
                Send s =  new Send();    
                Receive r =  new Receive();    
                 //要把输出连接到输入上去哈~    
                 try{    
                        r.getInput().connect(s.getOut());    
                } catch (Exception e){}    
                 new Thread(s).start();    
                 new Thread(r).start();    
        }    
}