[javaSE] IO流（管道流）

import java.io.IOException;
import java.io.PipedInputStream;
import java.io.PipedOutputStream;
/**
 * 读取数据线程
 * @author taoshihan
 *
 */
class ReadPipe implements Runnable{
    private PipedInputStream in;
    public ReadPipe(PipedInputStream in) {
        this.in=in;
    }
    @Override
    public void run() {
        System.out.println("开始读取。。。如果没有数据会阻塞");
        byte[] b=new byte[1024];
        try {
            int len=in.read(b);
            String info=new String(b,0,len);
            in.close();
            System.out.println(info);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
}
/**
 * 写入数据线程
 * @author taoshihan
 *
 */
class WritePipe implements Runnable{
    private PipedOutputStream out;
    public WritePipe(PipedOutputStream out) {
        this.out=out;
    }
    @Override
    public void run() {
        System.out.println("开始写入。。。延迟5秒");
        try {
            Thread.sleep(5000);
            out.write("我是数据".getBytes());
            out.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        
    }
    
}
public class PipeDemo {

    /**
     * @param args
     * @throws IOException 
     */
    public static void main(String[] args) throws IOException {
        //连接管道
        PipedInputStream in=new PipedInputStream();
        PipedOutputStream out=new PipedOutputStream();
        in.connect(out);
        //开启线程
        new Thread(new ReadPipe(in)).start();
        new Thread(new WritePipe(out)).start();
    }

}