1. package test01;
   
2. import java.io.*;
   
3. public class Pipe {
   
4. 
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                  PipedInputStream in = new PipedInputStream();
   
8.                  PipedOutputStream out = new PipedOutputStream();
   
9.                  in.connect(out);
   
10.                  ReadPiped r = new ReadPiped(in);
    
11.                  WritePipe w = new WritePipe(out);
    
12.                   new Thread(r).start();
    
13.                   new Thread(w).start();
    
14.         }
    
15. 
    
16. }
    
17. 
    
18. class ReadPiped implements Runnable
    
19. {
    
20.         private PipedInputStream in  ;
    
21.         public ReadPiped(PipedInputStream in) {
    
22.                  this.in = in;
    
23.         }
    
24.         public void run()
    
25.         {         
    
26.                 try {
    
27.                         byte [] buf = new byte [1024];
    
28.                         int len = in.read(buf);
    
29.                         String s = new String(buf,0,len);
    
30.                         System.out.println(s);
    
31.                         in.close();
    
32.                 } catch (Exception e) {
    
33.                         e.printStackTrace();
    
34.                 }
    
35.         }
    
36. }
    
37. 
    
38. class WritePipe implements Runnable
    
39. {
    
40. 
    
41.         private PipedOutputStream out;
    
42.         WritePipe(PipedOutputStream out)
    
43.         {
    
44.                 this.out = out;
    
45.         }
    
46.         public void run()
    
47.         {
    
48.                  
    
49.                 try {
    
50.                         out.write("wolaile".getBytes());
    
51.                         out.close();
    
52.                 } catch (Exception e) {
    
53.                         e.printStackTrace();
    
54.                 }
    
55.         }
    
56.        
    
57. }
    

复制代码

1. package test01;
   
2. import java.io.*;
   
3. public class Pipe {
   
4. 
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                  PipedInputStream in = new PipedInputStream();
   
8.                  PipedOutputStream out = new PipedOutputStream();
   
9.                  in.connect(out);
   
10.                  ReadPiped r = new ReadPiped(in);
    
11.                  WritePipe w = new WritePipe(out);
    
12.                   new Thread(r).start();
    
13.                   new Thread(w).start();
    
14.         }
    
15. 
    
16. }
    
17. 
    
18. class ReadPiped implements Runnable
    
19. {
    
20.         private PipedInputStream in  ;
    
21.         public ReadPiped(PipedInputStream in) {
    
22.                  this.in = in;
    
23.         }
    
24.         public void run()
    
25.         {         
    
26.                 try {
    
27.                         byte [] buf = new byte [1024];
    
28.                         int len = in.read(buf);
    
29.                         String s = new String(buf,0,len);
    
30.                         System.out.println(s);
    
31.                         in.close();
    
32.                 } catch (Exception e) {
    
33.                         e.printStackTrace();
    
34.                 }
    
35.         }
    
36. }
    
37. 
    
38. class WritePipe implements Runnable
    
39. {
    
40. 
    
41.         private PipedOutputStream out;
    
42.         WritePipe(PipedOutputStream out)
    
43.         {
    
44.                 this.out = out;
    
45.         }
    
46.         public void run()
    
47.         {
    
48.                  
    
49.                 try {
    
50.                         out.write("wolaile".getBytes());
    
51.                         out.close();
    
52.                 } catch (Exception e) {
    
53.                         e.printStackTrace();
    
54.                 }
    
55.         }
    
56.        
    
57. }
    

复制代码