1. import java.io.*;
   
2. class Read implements Runnable
   
3. {
   
4.         private PipedInputStream in;
   
5.         Read (PipedInputStream in)
   
6.         {
   
7.                 this.in = in;
   
8.         }
   
9.         public void run()
   
10.         {
    
11.                 try
    
12.                 {
    
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. class Write implements Runnable
    
29. {
    
30.         private PipedOutputStream out;
    
31.         Write(PipedOutputStream out)
    
32.         {
    
33.                 this.out = out;
    
34. 
    
35.         }
    
36.         public void run()
    
37.         {
    
38.                 try
    
39.                 {
    
40.                         System.out.println("开始写入数据，等待6秒。。。");
    
41.                         Thread.sleep(6000);
    
42.                         out.write("piped lai la".getBytes());
    
43.                         out.close();
    
44.                 }
    
45.                 catch (Exception e)
    
46.                 {
    
47.                         throw new RuntimeException("管道输出流失败");
    
48.                 }
    
49.         }
    
50. }
    
51. class PipedStreamDemo
    
52. {
    
53.         public static void main(String[] args) throws IOException
    
54.         {
    
55.                 PipedInputStream in = new PipedInputStream();
    
56.                 PipedOutputStream out = new PipedOutputStream();
    
57.                 in.connect(out);
    
58. 
    
59.                 Read r = new Read(in);
    
60.                 Write w = new Write(out);
    
61.                
    
62.                 new Thread(r).start();
    
63.                 new Thread(w).start();
    
64. 
    
65. //                in.close();
    
66. //                out.close();
    
67.         }
    
68. }
    

复制代码

PipedInputStream
PipedOutputStream
这两个流不是也需要关闭吗，在看视频的时候，没有说要关闭，我试着关闭了一下，就出问题了，求大神指点。。。

1. import java.io.*;
   
2. class Read implements Runnable
   
3. {
   
4.         private PipedInputStream in;
   
5.         Read (PipedInputStream in)
   
6.         {
   
7.                 this.in = in;
   
8.         }
   
9.         public void run()
   
10.         {
    
11.                 try
    
12.                 {
    
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. class Write implements Runnable
    
29. {
    
30.         private PipedOutputStream out;
    
31.         Write(PipedOutputStream out)
    
32.         {
    
33.                 this.out = out;
    
34. 
    
35.         }
    
36.         public void run()
    
37.         {
    
38.                 try
    
39.                 {
    
40.                         System.out.println("开始写入数据，等待6秒。。。");
    
41.                         Thread.sleep(6000);
    
42.                         out.write("piped lai la".getBytes());
    
43.                         out.close();
    
44.                 }
    
45.                 catch (Exception e)
    
46.                 {
    
47.                         throw new RuntimeException("管道输出流失败");
    
48.                 }
    
49.         }
    
50. }
    
51. class PipedStreamDemo
    
52. {
    
53.         public static void main(String[] args) throws IOException
    
54.         {
    
55.                 PipedInputStream in = new PipedInputStream();
    
56.                 PipedOutputStream out = new PipedOutputStream();
    
57.                 in.connect(out);
    
58. 
    
59.                 Read r = new Read(in);
    
60.                 Write w = new Write(out);
    
61.                
    
62.                 new Thread(r).start();
    
63.                 new Thread(w).start();
    
64. 
    
65. //                in.close();
    
66. //                out.close();
    
67.         }
    
68. }
    

复制代码

PipedInputStream
PipedOutputStream
这两个流不是也需要关闭吗，在看视频的时候，没有说要关闭，我试着关闭了一下，就出问题了，求大神指点。。。