java中PipedOutputStream和PipedInputStream类用法

ipedOutputStream和PipedInputStream用于在应用程序中创建管道通信

实例：

[java]
import java.io.*; 
 
public class PipedStreamTest { 
    public static void main(String [] args) { 
        Sender sender = new Sender(); 
        Receiver receiver = new Receiver(); 
         
        PipedOutputStream outStream = sender.getOutStream(); 
        PipedInputStream inStream = receiver.getInStream(); 
         
        try { 
            //inStream.connect(outStream); // 与下一句一样 
            outStream.connect(inStream); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
         
        sender.start(); 
        receiver.start(); 
    } 
} 
 
class Sender extends Thread { 
    private PipedOutputStream outStream = new PipedOutputStream(); 
     
    public PipedOutputStream getOutStream() { 
        return outStream; 
    } 
     
    public void run() { 
        String info = "hello, receiver"; 
         
        try { 
            outStream.write(info.getBytes()); 
             
            outStream.close(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    } 
} 
 
class Receiver extends Thread { 
    private PipedInputStream inStream = new PipedInputStream(); 
     
    public PipedInputStream getInStream() { 
        return inStream; 
    } 
     
    public void run() { 
        byte[] buf = new byte[1024]; 
         
        try { 
            int len = inStream.read(buf); 
             
            System.out.println("receive message from sender : " + new String(buf, 0, len)); 
             
            inStream.close(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
        } 
    }    
} 

补充：软件开发 , Java ,

上一个：设计模式---设计模式之外观模式
下一个：hadoop平台运行WordCount程序