管道流

PipedInputStream

流管道输入流应该连接到管道输出流；管道输入流提供要写入管道输出流的所有数据字。通常，数据由某个线程从 PipedInputStream 对象读取，并由其他线程将其写入到相应的 PipedOutputStream。不建议对这两个对象尝试使用单个线程，因为这样可能死锁线程。管道输入流包含一个缓冲区，可在缓冲区限定的范围内将读操作和写操作分离开。如果向连接管道输出流提供数据字节的线程不再存在，则认为该管道已损坏。

PipedOutputStream

可以将管道输出流连接到管道输入流来创建通信管道。管道输出流是管道的发送端。通常，数据由某个线程写入 PipedOutputStream 对象，并由其他线程从连接的 PipedInputStream 读取。不建议对这两个对象尝试使用单个线程，因为这样可能会造成该线程死锁。如果某个线程正从连接的管道输入流中读取数据字节，但该线程不再处于活动状态，则该管道被视为处于 毁坏 状态。

import java.io.*;

class Pipedstremdemo

{

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

        {

                PipedInputStream pis=new PipedInputStream();

                PipedOutputStream pos=new PipedOutputStream();

                pos.connect(pis);//管道输出流和管道输入流可也随意匹配链接

                Read r=new Read(pis);

                Write w=new Write(pos);

                new Thread(r).start();//创建管道读取线程

                new Thread(w).start();//创建管道输出线程               

        }

}

class Read implements Runnable

{

        private PipedInputStream pis;

        Read(PipedInputStream pis)

        {

        this.pis=pis;

        }

        public void run()

        {

                try

                {

                        byte[] by=new byte[1024*4];

                        int len=pis.read(by);

                        String str=new String(by,0,len);

                        System.out.println(str);//打印读取到得数据

                        pis.close();

               

                }

                catch (Exception e)

                {

                        throw new RuntimeException("管道读取失败");

                }

       

        }

}

class Write implements Runnable

{

        private PipedOutputStream pos;

        Write(PipedOutputStream pos)

        {

        this.pos=pos;

        }

        public void run()

        {

        try

        {

                //Thread.sleep(3000);

                pos.write("dfdfdfd".getBytes());//将string编码为byte序列

                pos.close();

               

        }

          catch (Exception e)

                {

                        throw new RuntimeException("管道输出失败");

                }

        }

}

值得学习ing!