Java PipedOutputStream类简介说明

PipedOutputStream类:
    定义一个管道输出流
 

PipedOutputStream类构造函数

public PipedOutputStream()
public PipedOutputStream(PipedInputStream snk)
参数说明
   snk:要连接的管道输入流

PipedOutputStream类中方法

//将指定的字节写入管道输出流
public void write(int b)
public void write(byte[] b,int off,int len)
将指定的字节写入此字节数组输出流,此方法继承于OutputStream,可参考OutputStream.write
//关闭流
public void close()
public void flush()

class Write implements Runnable
{
    private PipedOutputStream out;
    Write(PipedOutputStream out)
    {
        this.out = out;
    }
    public void run()
    {
        try
        {
            Thread.sleep(1000);
            out.write("欢迎来到 www.java265.com".getBytes());
            out.close();
        }
        catch(Exception e)
        {}
    }
}
class Read implements Runnable
{
    private PipedInputStream in ;
    Read(PipedInputStream in )
    {
        this.in = in ;
    }
    public void run()
    {
        try
        {
            byte[] buf = new byte[1024];
            int len = in .read(buf);
            String s = new String(buf, 0, len);
            System.out.println("读取到的数据：" + s); in .close();
        }
        catch(IOException e)
        {}
    }
}
public static void main(String[] args)
{
    PipedInputStream in = new PipedInputStream();
    PipedOutputStream out = new PipedOutputStream(); 
    in.connect(out); // 管道连接
    Read r = new Read( in );
    Write w = new Write(out);
    // 开启线程
    new Thread(r).start();
    new Thread(w).start();
}