pipeapp.java

<Java编程精选集锦>随书源码

//
//PipeApp.java--The Main PipeApp Application
//

import java.io.*;

class PipeApp
{
    public static void main(String[] args)
    {
        PipeApp pipeApp = new PipeApp();
        try
        {
            FileInputStream XFileIn = new FileInputStream("input.txt");
            InputStream YInPipe = pipeApp.changeToY(XFileIn);
            InputStream ZInPipe = pipeApp.changeToZ(YInPipe);
            System.out.println();
            System.out.println("Here are the results:");
            System.out.println();
            DataInputStream inputStream = new DataInputStream(ZInPipe);
            String str = inputStream.readLine();
            while (str != null)
            {
                System.out.println(str);
                str = inputStream.readLine();
            }
            inputStream.close();
        }
        catch (Exception e)
        {
            System.out.println(e.toString());
        }
    }
    public InputStream changeToY(InputStream inputStream)
    {
        try
        {
            DataInputStream XFileIn = new DataInputStream(inputStream);
            PipedOutputStream pipeOut = new PipedOutputStream();
            PipedInputStream pipeIn = new PipedInputStream(pipeOut);
            PrintStream printStream = new PrintStream(pipeOut);
            YThread yThread = new YThread(XFileIn, printStream);
            yThread.start();
            return pipeIn;
        }
        catch (Exception e)
        {
            System.out.println(e.toString());
        }
        return null;
    }
    public InputStream changeToZ(InputStream inputStream)
    {
        try
        {
            DataInputStream YFileIn = new DataInputStream(inputStream);
            PipedOutputStream pipeOut2 = new PipedOutputStream();
            PipedInputStream pipeIn2 = new PipedInputStream(pipeOut2);
            PrintStream printStream2 = new PrintStream(pipeOut2);
            ZThread zThread = new ZThread(YFileIn, printStream2);
            zThread.start();
            return pipeIn2;
        }
        catch (Exception e)
        {
            System.out.println(e.toString());
        }
        return null;
    }
}