|
管道流 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("管道输出失败"); } } }
| 
收藏
淘帖
踩
