JAVA中管道流（线程间通讯）例子

JAVA中管道通讯（线程间通讯）例子

 

　　下面例子中使用Java中的PipedInputStream类和PipedOutputStream类，给大家演示如何在Java中实现线程间的数据传送。

　　

package lesson.io.test;
 
 import java.io.*;
 
 public class TestPiped
 {
 
     public static void main(String[] args)
     {
         
         Sender sender = new Sender();
         Recive recive = new Recive();
         PipedInputStream pi=recive.getPipedInputputStream();
         PipedOutputStream po=sender.getPipedOutputStream();
         try
         {
             pi.connect(po);
         } catch (IOException e)
         {
             System.out.println(e.getMessage());
         }
         sender.start();
         recive.start();
         
     
     }
 
 }
 
 class Sender extends Thread
 {
      PipedOutputStream out = null;
 
     public PipedOutputStream getPipedOutputStream()
     {
         out = new PipedOutputStream();
         return out;
     }
 
     @Override
     public void run()
     {
         
         try
         {
             out.write("Hello , Reciver!".getBytes());
         } catch (IOException e)
         {
             System.out.println(e.getMessage());
         }
         try
         {
             out.close();
         } catch (IOException e)
         {
             System.out.println(e.getMessage());
         }
 
     }
 
 }
 
 
 class Recive extends Thread
 {
     PipedInputStream in = null;
 
     public PipedInputStream getPipedInputputStream()
     {
         in = new PipedInputStream();
         return in;
     }
 
     @Override
     public void run()
     {
     
         byte[] bys = new byte[1024];
         try
         {
             in.read(bys);
             System.out.println("读取到的信息：" + new String(bys).trim());
             in.close();
         } catch (IOException e)
         {
             System.out.println(e.getMessage());
         }
 
     }
 }
 

运行后效果如下：