java基础知识回顾之javaIO类--管道流PipedOutputStream和PipedIutputStream

package com.lp.ecjtu.io.piped;

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

public class PipedDemo {

    public static void main(String[] args) {
        PipedOutputStream out = new PipedOutputStream();
        PipedInputStream in = new PipedInputStream();
        try {
            out.connect(in);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }//输出管道流连接输入管道流
        new Thread(new OutputThread(out)).start();
        new Thread(new InputThread(in)).start();
    }

}

class InputThread implements Runnable{
    private PipedInputStream in;
    public InputThread(PipedInputStream in){
        this.in = in;
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        
        try {
            byte[] buff = new byte[1024];
            int len = in.read(buff);
            String s = new String(buff,0,len);
            System.out.println(s);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

class OutputThread implements Runnable{
    private PipedOutputStream out;
    public OutputThread(PipedOutputStream out){
        this.out = out;
    }

    @Override
    public void run() {
        String str = "hello Piped!";
        try {
            out.write(str.getBytes());
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                if(out != null){
                    out.close();
                }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        
    }
}