package org.fun.io;

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

class Send implements Runnable{
    private PipedOutputStream output=null;
    public Send(){
    	this.output=new PipedOutputStream();
    }
    public PipedOutputStream getPipedOutputStream(){
    	return this.output;
    }
	public void run() {
       String str="hello world!";
       try{
    	   this.output.write(str.getBytes());
       }catch(IOException e){
    	   e.printStackTrace();
       }
       try{
    	   this.output.close();
       }catch(IOException e){
    	   e.printStackTrace();
       }
	}
	
}
class Receive implements Runnable{
	private PipedInputStream input=null;
    public Receive(){
    	this.input=new PipedInputStream();
    }
    public PipedInputStream getPipedInputStream(){
    	return this.input;
    }
	public void run() {
        byte[] b=new byte[1024];
        int len=0;
        try {
			len=this.input.read(b);
		} catch (IOException e) {
			e.printStackTrace();
		}
        try {
			input.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
        System.out.println(new String(b,0,len));
	}
}
public class PipedDemo {

	
	public static void main(String[] args) throws IOException {
         Send send=new Send();
         Receive rec=new Receive();
         send.getPipedOutputStream().connect(rec.getPipedInputStream());
         new Thread(send).start();
         new Thread(rec).start();
	}
}