管道流通信


import  java.io.PipedOutputStream;
 import  java.io.PipedInputStream;

 public   class  Main  {
     public  Main() {
    }
     public   static   void  main(String[] args)   throws  Exception {
        PipedOutputStream pos = new  PipedOutputStream();
        PipedInputStream pis = new  PipedInputStream();
        pos.connect(pis);
        producer p = new  producer(pos);
        p.run();
        consumer c = new  consumer(pis);
        c.run();
    }
    
}

class  producer  extends  Thread {
     private  PipedOutputStream pos;
    producer(PipedOutputStream pos) {
         this .pos = pos;
    }
     public   void  run() {
         try {
            pos.write( " send a message " .getBytes());
            pos.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

class  consumer  extends  Thread {
     private  PipedInputStream pis;
    consumer(PipedInputStream pis) {
         this .pis = pis;
    }
     public   void  run() {
         byte  b[] = new   byte [ 100 ];
         try {
             int  len = pis.read(b);
            System.out.println( new  String(b, 0 ,len));
        } catch (Exception e) {
        e.printStackTrace();
        }
        
    }
}