A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© 奋发吧小白 高级黑马   /  2014-10-9 15:02  /  695 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

  1. package test01;
  2. import java.io.*;
  3. public class Pipe {

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

  14. }

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

  34. class WritePipe implements Runnable
  35. {

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


0 个回复

您需要登录后才可以回帖 登录 | 加入黑马