java PipedOutputStream、PipedInputStream的使用

1、管道流的使用

package cn.kongxh.io6;
import java.io.* ;
class Send implements Runnable{            // 線程類
    private PipedOutputStream pos = null ;    // 管道輸出流
    public Send(){
        this.pos = new PipedOutputStream() ;    // 實例化輸出流
    }
    public void run(){
        String str = "Hello World!!!" ;    // 要輸出的內容
        try{
            this.pos.write(str.getBytes()) ;
        }catch(IOException e){
            e.printStackTrace() ;
        }
        try{
            this.pos.close() ;
        }catch(IOException e){
            e.printStackTrace() ;
        }
    }
    public PipedOutputStream getPos(){    // 得到此線程的管道輸出流
        return this.pos ;    
    }
};
class Receive implements Runnable{
    private PipedInputStream pis = null ;    // 管道輸入流
    public Receive(){
        this.pis = new PipedInputStream() ;    // 實例化輸入流
    }
    public void run(){
        byte b[] = new byte[1024] ;    // 接收內容
        int len = 0 ;
        try{
            len = this.pis.read(b) ;    // 讀取內容
        }catch(IOException e){
            e.printStackTrace() ;
        }
        try{
            this.pis.close() ;    // 關閉
        }catch(IOException e){
            e.printStackTrace() ;
        }
        System.out.println("接收的內容為：" + new String(b,0,len)) ;
    }
    public PipedInputStream getPis(){
        return this.pis ;
    }
};
public class PipedDemo{
    public static void main(String args[]){
        Send s = new Send() ;
        Receive r = new Receive() ;
        try{
            s.getPos().connect(r.getPis()) ;    // 連接管道
        }catch(IOException e){
            e.printStackTrace() ;
        }
        new Thread(s).start() ;    // 啟動線程
        new Thread(r).start() ;    // 啟動線程
    }
};