黑马程序员技术交流社区

标题: 对视频教程中管道流代码的一点小小的优化 [打印本页]
作者: 王金科    时间: 2012-8-20 18:26
标题: 对视频教程中管道流代码的一点小小的优化
教程中原代码:
  1. package cn.study.file;

  3. import java.io.*;

  5. public class  PipedStreamDemo1
  6. {
  7.         public static void main(String[] args) throws IOException
  8.         {
  9.                 PipedInputStream in = new PipedInputStream();
  10.                 PipedOutputStream out = new PipedOutputStream();
  11.                 in.connect(out);
  12.                 Read r = new Read(in);
  13.                 Write w = new Write(out);
  14.                
  15.                 new Thread(w).start();
  16.                 new Thread(r).start();
  17.         }
  18. }

  20. class Read implements Runnable
  21. {
  22.         private PipedInputStream in;
  23.         Read(PipedInputStream in)
  24.         {
  25.                 this.in = in;
  26.         }
  27.         public void run()
  28.         {
  29.                 try
  30.                 {
  31.                         byte[] buf = new byte[1024];
  32.                         System.out.println("读取前，没有数据，阻塞...");
  33.                         int len = in.read(buf);
  34.                         System.out.println("读到数据了");
  35.                         String s = new String(buf,0,len);
  36.                         System.out.println(s);
  37.                         in.close();
  38.                 }
  39.                 catch (IOException e)
  40.                 {
  41.                         throw new RuntimeException("管道读取流失败");
  42.                 }
  43.         }
  44. }

  46. class Write implements Runnable
  47. {
  48.         private PipedOutputStream out;
  49.         Write(PipedOutputStream out)
  50.         {
  51.                 this.out = out;
  52.         }
  53.         public void run()
  54.         {
  55.                 try
  56.                 {
  57.                         System.out.println("开始写入数据，等待6秒...");
  58.                         Thread.sleep(6000);
  59.                         out.write("pipde 来了".getBytes());
  60.                         out.close();
  61.                 }
  62.                 catch (Exception e)
  63.                 {
  64.                         throw new RuntimeException("管道输出流失败");
  65.                 }
  66.         }
  67. }
复制代码
我优化后的代码
  1. package cn.study.file;

  3. import java.io.IOException;
  4. import java.io.PipedInputStream;
  5. import java.io.PipedOutputStream;

  7. public class PipedStreamDemo {

  9.         /**
  10.          * @param args
  11.          * @throws IOException
  12.          */
  13.         public static void main(String[] args) throws IOException {
  14.                 // TODO Auto-generated method stub

  16.                 final PipedInputStream pis = new PipedInputStream();
  17.                 final PipedOutputStream pos = new PipedOutputStream();
  18.                
  19.                 Thread read = new Thread(){
  20.                         public void run(){
  21.                                 try {
  22.                                         byte[] buf = new byte[1024];
  23.                                         System.out.println("读取前,没有数据,等待...");
  24.                                         int len = pis.read(buf);
  25.                                         System.out.println("读到数据,打印数据...");
  26.                                         String str = new String(buf,0,len);
  27.                                         System.out.println(str);
  28.                                         pis.close();
  29.                                 } catch (IOException e) {
  30.                                         // TODO Auto-generated catch block
  31.                                         e.printStackTrace();
  32.                                 }
  33.                         }
  34.                 };
  35.                
  36.                 Runnable write = new Runnable(){
  37.                         public void run(){
  38.                                 try {
  39.                                         System.out.println("开始写入数据,等待6秒后...");
  40.                                         Thread.sleep(6000);
  41.                                         pos.write("piped lai la".getBytes());
  42.                                         pos.close();
  43.                                 } catch (Exception e) {
  44.                                         // TODO Auto-generated catch block
  45.                                         e.printStackTrace();
  46.                                 }
  47.                         }
  48.                 };
  49.                 pis.connect(pos);
  50.                 read.start();
  51.                 new Thread(write).start();               
  52.         }
  53. }
复制代码
大家帮我看看这样会不会有什么缺陷





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