先贴代码

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. }
    
28. 
    
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 {
    
55. 
    
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.                
    
66. 
    
67.         }
    
68. 
    
69. }
    

复制代码

为什么我执行的结果每次都一样，应该输入输出流都有可能先执行的啊，试了N遍都一样

我运行了一下,你先开启写入数据线程,写入就先执行了,就是把最后两句代码调换.可能是线程运行太快,如果数据太少,如果数据多的话,看的就明显了

我试了三次，输入输出流有交替先运行的情况