Java基础之管道流对象 PipedInputStream / PipedOutputStream

管道流 PipedInputStream / PiedOutputStream 说明：输入输出可以直接进行连接，通过结合线程使用。

import java.io.*;



class PipedStreamDemo

{

    public static void main(String[] args) throws Exception

    {

        PipedInputStream in = new PipedInputStream();

        PipedOutputStream out = new PipedOutputStream();

        

        in.connect(out);

        

        new Thread(new Reader(in)).start();

        new Thread(new Writer(out)).start();

    }

}



class Reader implements Runnable

{

    private PipedInputStream in;

    public Reader(PipedInputStream in)

    {

        this.in = in;

    }

    

    public void run()

    {

        try        

        {

            byte[] buffer = new byte[1024];

            int length = 0;

            System.out.println("等待读取数据...");

            while((length=in.read(buffer))!=-1)

            {

                System.out.println(new String(buffer,0,length));

            }

            

            in.close();

        }

        catch(Exception e)

        {

            throw new RuntimeException(e.getMessage());

        }

    }

}



class Writer implements Runnable

{

    private PipedOutputStream out;

    public Writer(PipedOutputStream out)

    {

        this.out = out;

    }

    

    public void run()

    {

        try        

        {

            System.out.println("六秒后开始写入数据...");

            Thread.sleep(6000);

            out.write("hello PipedStream here.".getBytes());

            out.close();

        }

        catch(Exception e)

        {

            throw new RuntimeException(e.getMessage());

        }

    }

}