java io之管道流

import java.io.PipedInputStream;import java.io.PipedOutputStream;public class PipeStream {    //管道输出流    private static PipedOutputStream outputStream = new PipedOutputStream();    //管道输入流    private static PipedInputStream inputStream = new PipedInputStream();    public static void main(String[] args) throws Exception {        //输出线程        Runnable out = ()-> {            try {                while(true) {                    Thread.sleep(1000);                    outputStream.write("pipe".getBytes());                }            } catch (Exception e) {                e.printStackTrace();            }        };        //输入线程        Runnable in = ()-> {            try {                byte[] bytes = new byte [1024];                int len;                while ((len = inputStream.read(bytes)) != -1) {                    System.out.println(new String(bytes,0,len));                }            } catch (Exception e) {                e.printStackTrace();            }        };        //连接管道        inputStream.connect(outputStream);        //启动线程        new Thread(out).start();        new Thread(in).start();    }}