import java.io.*;
public class Pipedstream
{
    public static void main (String args[])
    {
        PipedInputStream in = new PipedInputStream();
        PipedOutputStream out = new PipedOutputStream();
        try
        {
             in.connect(out);
        }
        catch(IOException ioe)   {  }
        Send s1 = new Send(out,1);
        Send s2 = new Send(out,2);
        Receive r1 = new Receive(in);
        Receive r2 = new Receive(in);
        s1.start();
        s2.start();
        r1.start();
        r2.start();
    }
}
class Send extends Thread                //發送線程
{
    PipedOutputStream out;
    static int count=0;                  //記錄線程個數
    int k=0;
    public Send(PipedOutputStream out,int k)
    {
        this.out= out;
        this.k= k;
        this.count++;                    //線程個數加1
    }
    public void run( )
    {
        System.out.print("\r\nSend"+this.k+":   "+this.getName()+"  ");
        int i=k;
        try 
        {
            while (i<10)
            {
                out.write(i);
                i+=2;
                sleep(1);
            }
            if (Send.count==1)           //只剩一個線程時
            {
                out.close();             //關閉輸入管道流
                System.out.println("  out closed!");
            }    
            else
                this.count--;            //線程個數減1 
        }
        catch(InterruptedException e)   {  }
        catch(IOException e)   { }
    }
}
class Receive extends Thread             //接收線程
{
    PipedInputStream in;
    public Receive(PipedInputStream in)
    {
        this.in = in;
    }
    public void run( )
    {
        System.out.print("\r\nReceive: "+this.getName()+"  ");
        try
        {
            int i = in.read();
            while (i!=-1)                //輸入流未結束時
            {
                System.out.print(i+"  ");
                i = in.read();
                sleep(1);
            }
            in.close();                  //關閉輸入管道流
        }
        catch(InterruptedException e)  { }
        catch(IOException e)
        {
            System.out.println(e);
        }
    }
}