黑马程序员技术交流社区

标题: 管道流的问题 [打印本页]
作者: 奔跑的二叉树    时间: 2013-9-20 10:26
标题: 管道流的问题
本帖最后由 奔跑的二叉树 于 2013-9-20 20:54 编辑

先贴代码
  1. package cn.os.du;
  2. import java.io.*;
  3. class Read implements Runnable
  4. {
  5.         private PipedInputStream in;
  6.         Read(PipedInputStream in)
  7.         {
  8.                 this.in=in;
  9.         }
  10.         public void run()
  11.         {
  12.                 try
  13.                 {
  14.                         byte[] buf =new byte[1024];
  15.                         System.out.println("读取前 ..没有数据阻塞");
  16.                         int len=in.read(buf);
  17.                         System.out.println("读到数据 ..阻塞结束");
  18.                         String s=new String(buf,0,len);
  19.                         System.out.println(s);
  20.                         in.close();
  21.                 }
  22.                 catch(IOException e)
  23.                 {
  24.                         throw new RuntimeException("管道读取流失败");
  25.                 }
  26.         }
  27. }

  29. class Write implements Runnable
  30. {
  31.         private PipedOutputStream out;
  32.         Write(PipedOutputStream out)
  33.         {
  34.                 this.out=out;
  35.         }
  36.         public void run()
  37.         {
  38.                 try
  39.                 {
  40.                         System.out.println("开始写入数据------------------------，等待1秒后。");
  41.                         Thread.sleep(500);
  42.                         out.write("piped lai la".getBytes());
  43.                         out.close();
  44.                 }
  45.                 catch(IOException e)
  46.                 {
  47.                         throw new RuntimeException("管道输出流失败");
  48.                 } catch (Exception e) {
  49.                         // TODO Auto-generated catch block
  50.                         e.printStackTrace();
  51.                 }
  52.         }
  53. }
  54. public class pipedStream {

  56.         public static void main(String[] args) throws IOException {
  57.                 PipedInputStream in=new PipedInputStream();
  58.                 PipedOutputStream out=new PipedOutputStream();
  59.                 in.connect(out);//连接管道 输入输出流
  60.                
  61.                 Read r=new Read(in);
  62.                 Write w=new Write(out);
  63.                 new Thread(r).start();
  64.                 new Thread(w).start();
  65.                

  67.         }

  69. }
复制代码
为什么我执行的结果每次都一样，应该输入输出流都有可能先执行的啊，试了N遍都一样
作者: yuchunfeng1221    时间: 2013-9-20 14:39
我运行了一下,你先开启写入数据线程,写入就先执行了,就是把最后两句代码调换.可能是线程运行太快,如果数据太少,如果数据多的话,看的就明显了
作者: 神之梦    时间: 2013-9-20 14:46
我试了三次，输入输出流有交替先运行的情况



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