PipedInputStream和PipedOutputStream

import java.io.PipedInputStream;
import java.io.PipedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;

class ReadThread extends Thread
{
    public PipedInputStream in;
    
    public ReadThread(PipedInputStream in)
    {
        this.in = in;
    }
    
    public void connect(PipedOutputStream out) throws Exception
    {
        in.connect(out);
    }
    
    public void run()
    {
        try
        {
            byte[] data = new byte[1024];
            int len;
            
            len = in.read(data, 0, 1024);
            in.close();
            
            DataOutputStream out = new DataOutputStream(System.out);
            out.write(data, 0, len);
        }
        catch (Exception e)
        {
            System.out.println(e.getMessage());
        }
    }
}

class WriteThread extends Thread
{
    public PipedOutputStream out;
    
    public WriteThread(PipedOutputStream out)
    {
        this.out = out;
    }
    
    public void connect(PipedInputStream in) throws Exception
    {
        out.connect(in);
    }
    
    public void run()
    {
        try
        {
            DataInputStream in = new DataInputStream(System.in);
            byte[] data = new byte[1024];
            int len = in.read(data, 0, 1024);
            out.write(data, 0, len);
            out.flush();
            out.close();
        }
        catch (Exception e)
        {
            System.out.println(e.getMessage());
        }
    }
}

public class Test
{
    public static void main(String args[]) throws Exception
    {
        PipedInputStream in = new PipedInputStream();
        PipedOutputStream out = new PipedOutputStream();
        
        ReadThread reader = new ReadThread(in);
        WriteThread writer = new WriteThread(out);
        
        writer.connect(in);
        
        reader.start();
        writer.start();
    }
}