PipedOutputStream&PipedInputStream---管道流

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

public class PipedStreamDemo {

    public static void main(String[] args) throws IOException {
        
        //管道流和多线程技术相结合
        PipedInputStream pis =new PipedInputStream();
        PipedOutputStream pos = new PipedOutputStream();
        
        //将两个流连接上。
        pis.connect(pos);
        new Thread(new Input(pis)).start();
        new Thread(new Output(pos)).start();
        
    }

}
//定义输入任务
class Input implements Runnable{
    
    private PipedInputStream pis;
    
    public Input(PipedInputStream pis) {
        super();
        this.pis = pis;
    }
    @Override
    public void run() {
        
        byte[] buf = new byte[1024];
        int len;
        try {
            len = pis.read(buf);
            String str = new String(buf,0,len);
            System.out.println(str);
            pis.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
}

//定义输出任务
class Output implements Runnable{
    PipedOutputStream pos;
    
    
    public Output(PipedOutputStream pos) {
        super();
        this.pos = pos;
    }


    @Override
    public void run() {
        
        //通过写方法完成
        try {
            pos.write("嘿,管道来了".getBytes());
            
            pos.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
    }
    
    
}