黑马程序员技术交流社区

标题: 管道流回看 [打印本页]
作者: 奋发吧小白    时间: 2014-10-9 15:02
标题: 管道流回看
  1. package test01;
  2. import java.io.*;
  3. public class Pipe {

  5.         public static void main(String[] args) throws Exception
  6.         {
  7.                  PipedInputStream in = new PipedInputStream();
  8.                  PipedOutputStream out = new PipedOutputStream();
  9.                  in.connect(out);
  10.                  ReadPiped r = new ReadPiped(in);
  11.                  WritePipe w = new WritePipe(out);
  12.                   new Thread(r).start();
  13.                   new Thread(w).start();
  14.         }

  16. }

  18. class ReadPiped implements Runnable
  19. {
  20.         private PipedInputStream in  ;
  21.         public ReadPiped(PipedInputStream in) {
  22.                  this.in = in;
  23.         }
  24.         public void run()
  25.         {         
  26.                 try {
  27.                         byte [] buf = new byte [1024];
  28.                         int len = in.read(buf);
  29.                         String s = new String(buf,0,len);
  30.                         System.out.println(s);
  31.                         in.close();
  32.                 } catch (Exception e) {
  33.                         e.printStackTrace();
  34.                 }
  35.         }
  36. }

  38. class WritePipe implements Runnable
  39. {

  41.         private PipedOutputStream out;
  42.         WritePipe(PipedOutputStream out)
  43.         {
  44.                 this.out = out;
  45.         }
  46.         public void run()
  47.         {
  48.                  
  49.                 try {
  50.                         out.write("wolaile".getBytes());
  51.                         out.close();
  52.                 } catch (Exception e) {
  53.                         e.printStackTrace();
  54.                 }
  55.         }
  56.        
  57. }
复制代码






欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2