1. import java.io.*;
   
2. class Read implements Runnable
   
3. {
   
4.         private PipedInputStream pis;
   
5.         public Read(PipedInputStream pis)
   
6.         {
   
7.                 this.pis=pis;
   
8.         }
   
9.         public void run()
   
10.         {
    
11.                 byte[] buf=new byte[1024];
    
12.                 int len=0;
    
13.                 System.out.println("开始读取数据！");
    
14.                 try
    
15.                 {
    
16.                         len=pis.read(buf);
    
17.                 }
    
18.                 catch (IOException e)
    
19.                 {
    
20.                         throw new RuntimeException("读取数据失败！");
    
21.                 }
    
22.                 System.out.println("数据读取完毕！");
    
23.                 System.out.println(new String(buf,0,len));
    
24.         }
    
25. }
    
26. class Write implements Runnable
    
27. {
    
28.         private PipedOutputStream pos;
    
29.         public Write(PipedOutputStream pos)
    
30.         {
    
31.                 this.pos=pos;
    
32.         }
    
33.         public void run()
    
34.         {
    
35.                 System.out.println("5秒后写入数据,进入阻塞！");
    
36.                 try
    
37.                 {
    
38.                         Thread.sleep(5000);
    
39.                 }
    
40.                 catch (InterruptedException e)
    
41.                 {
    
42.                         e.getMessage();
    
43.                 }
    
44.                 try
    
45.                 {
    
46.                         pos.write("hehehe".getBytes());
    
47.                 }
    
48.                 catch (IOException e)
    
49.                 {
    
50.                         throw new RuntimeException("数据写出失败！");
    
51.                 }
    
52.                 System.out.println("数据写入完毕,解除阻塞!");
    
53.         }
    
54. }
    
55. class PipedStreamDemo
    
56. {
    
57.         public static void main(String[] args)
    
58.         {
    
59.                 PipedInputStream pis=null;
    
60.                 PipedOutputStream pos=null;
    
61.                 try
    
62.                 {
    
63.                         pis=new PipedInputStream();
    
64.                         pos=new PipedOutputStream();
    
65.                         pos.connect(pis);
    
66.                 }
    
67.                 catch (IOException e)
    
68.                 {
    
69.                         throw new RuntimeException("管道连接失败！");
    
70.                 }
    
71.                 new Thread(new Write(pos)).start();
    
72.                 new Thread(new Read(pis)).start();
    
73.         }
    
74. }
    

复制代码

到底是管道输出到输入，还是输入到输出

1. import java.io.*;
   
2. class Read implements Runnable
   
3. {
   
4.         private PipedInputStream pis;
   
5.         public Read(PipedInputStream pis)
   
6.         {
   
7.                 this.pis=pis;
   
8.         }
   
9.         public void run()
   
10.         {
    
11.                 byte[] buf=new byte[1024];
    
12.                 int len=0;
    
13.                 System.out.println("开始读取数据！");
    
14.                 try
    
15.                 {
    
16.                         len=pis.read(buf);
    
17.                 }
    
18.                 catch (IOException e)
    
19.                 {
    
20.                         throw new RuntimeException("读取数据失败！");
    
21.                 }
    
22.                 System.out.println("数据读取完毕！");
    
23.                 System.out.println(new String(buf,0,len));
    
24.         }
    
25. }
    
26. class Write implements Runnable
    
27. {
    
28.         private PipedOutputStream pos;
    
29.         public Write(PipedOutputStream pos)
    
30.         {
    
31.                 this.pos=pos;
    
32.         }
    
33.         public void run()
    
34.         {
    
35.                 System.out.println("5秒后写入数据,进入阻塞！");
    
36.                 try
    
37.                 {
    
38.                         Thread.sleep(5000);
    
39.                 }
    
40.                 catch (InterruptedException e)
    
41.                 {
    
42.                         e.getMessage();
    
43.                 }
    
44.                 try
    
45.                 {
    
46.                         pos.write("hehehe".getBytes());
    
47.                 }
    
48.                 catch (IOException e)
    
49.                 {
    
50.                         throw new RuntimeException("数据写出失败！");
    
51.                 }
    
52.                 System.out.println("数据写入完毕,解除阻塞!");
    
53.         }
    
54. }
    
55. class PipedStreamDemo
    
56. {
    
57.         public static void main(String[] args)
    
58.         {
    
59.                 PipedInputStream pis=null;
    
60.                 PipedOutputStream pos=null;
    
61.                 try
    
62.                 {
    
63.                         pis=new PipedInputStream();
    
64.                         pos=new PipedOutputStream();
    
65.                         pos.connect(pis);
    
66.                 }
    
67.                 catch (IOException e)
    
68.                 {
    
69.                         throw new RuntimeException("管道连接失败！");
    
70.                 }
    
71.                 new Thread(new Write(pos)).start();
    
72.                 new Thread(new Read(pis)).start();
    
73.         }
    
74. }
    

复制代码

到底是管道输出到输入，还是输入到输出