Java学习之IO流（管道流--PipedStream）

管道流
PipedInputStream
PipedOutputStream

注意：输入流和输出流必须在不同的线程中

public class PipedStreamDemo {

    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {
    PipedInputStream input = new PipedInputStream();
    PipedOutputStream output = new PipedOutputStream();

    input.connect(output);
    new Thread(new Input(input)).start();
    new Thread(new Out(output)).start();

    }
}

class Input implements Runnable {

    private PipedInputStream in;

    public Input(PipedInputStream in) {
        this.in = in;
    }

    @Override
    public void run() {
        byte[] buf = new byte[1024];
        int len;
        try {
        len = in.read(buf);
        String str = new String(buf, 0, len);
        System.out.println(str);
        this.in.close();
        } catch (IOException e) {

        }

    }

}

class Out implements Runnable {

    private PipedOutputStream out;

    Out(PipedOutputStream out) {
        this.out = out;
    }

    @Override
    public void run() {
        try {
        out.write("管道流".getBytes());
        out.close();
        } catch (IOException e) {

        }
    }

}