1. import java.io.IOException;
   
2. import java.io.PipedInputStream;
   
3. import java.io.PipedOutputStream;
   
4. 
   
5. class Read implements Runnable{
   
6.         private PipedInputStream in;
   
7.         Read(PipedInputStream in){
   
8.                 this.in = in;
   
9.         }
   
10.         @Override
    
11.         public void run() {
    
12.                 byte[] b = new byte[1024];
    
13.                 int len = 0;
    
14.                 try {
    
15.                         System.out.println("xiuxiyixia 6miao");
    
16.                         Thread.sleep(6000);
    
17.                         len = in.read(b);
    
18.                         System.out.println(new String(b, 0, len));
    
19.                 } catch (Exception e) {
    
20.                         throw new RuntimeException("管道流读取失败");
    
21.                 }
    
22.                 finally{
    
23.                                 if(in!=null)
    
24.                                 try {
    
25.                                         in.close();
    
26.                                 } catch (IOException e) {
    
27.                                         e.printStackTrace();
    
28.                                 }
    
29.                 }       
    
30.         }
    
31.        
    
32. }
    
33. class Write implements Runnable{
    
34.         private PipedOutputStream out;
    
35.         Write(PipedOutputStream out){
    
36.                 this.out = out;
    
37.         }
    
38.         @Override
    
39.         public void run() {
    
40.                 try {
    
41.                  out.write("asdasdasfwq".getBytes());;
    
42.                 } catch (IOException e) {
    
43.                         throw new RuntimeException("管道流写入取失败");
    
44.                 }
    
45.                 finally{
    
46.                                 if(out!=null)
    
47.                                 try {
    
48.                                         out.close();
    
49.                                 } catch (IOException e) {
    
50.                                         e.printStackTrace();
    
51.                                 }
    
52.                 }
    
53.                
    
54.         }
    
55.        
    
56. }
    
57. public class PipedStreamTest {
    
58. 
    
59.         public static void main(String[] args) throws IOException {
    
60.                 PipedInputStream in = new PipedInputStream();
    
61.                 PipedOutputStream out = new PipedOutputStream();
    
62.                 in.connect(out);//这里的我们可以用out去连接in吗？
    
63.                 Read r = new Read(in);
    
64.                 Write w = new Write(out);
    
65.                 new Thread(r).start();
    
66.                 new Thread(w).start();       
    
67.         }
    
68. }
    

复制代码

1. import java.io.IOException;
   
2. import java.io.PipedInputStream;
   
3. import java.io.PipedOutputStream;
   
4. 
   
5. class Read implements Runnable{
   
6.         private PipedInputStream in;
   
7.         Read(PipedInputStream in){
   
8.                 this.in = in;
   
9.         }
   
10.         @Override
    
11.         public void run() {
    
12.                 byte[] b = new byte[1024];
    
13.                 int len = 0;
    
14.                 try {
    
15.                         System.out.println("xiuxiyixia 6miao");
    
16.                         Thread.sleep(6000);
    
17.                         len = in.read(b);
    
18.                         System.out.println(new String(b, 0, len));
    
19.                 } catch (Exception e) {
    
20.                         throw new RuntimeException("管道流读取失败");
    
21.                 }
    
22.                 finally{
    
23.                                 if(in!=null)
    
24.                                 try {
    
25.                                         in.close();
    
26.                                 } catch (IOException e) {
    
27.                                         e.printStackTrace();
    
28.                                 }
    
29.                 }       
    
30.         }
    
31.        
    
32. }
    
33. class Write implements Runnable{
    
34.         private PipedOutputStream out;
    
35.         Write(PipedOutputStream out){
    
36.                 this.out = out;
    
37.         }
    
38.         @Override
    
39.         public void run() {
    
40.                 try {
    
41.                  out.write("asdasdasfwq".getBytes());;
    
42.                 } catch (IOException e) {
    
43.                         throw new RuntimeException("管道流写入取失败");
    
44.                 }
    
45.                 finally{
    
46.                                 if(out!=null)
    
47.                                 try {
    
48.                                         out.close();
    
49.                                 } catch (IOException e) {
    
50.                                         e.printStackTrace();
    
51.                                 }
    
52.                 }
    
53.                
    
54.         }
    
55.        
    
56. }
    
57. public class PipedStreamTest {
    
58. 
    
59.         public static void main(String[] args) throws IOException {
    
60.                 PipedInputStream in = new PipedInputStream();
    
61.                 PipedOutputStream out = new PipedOutputStream();
    
62.                 in.connect(out);//这里的我们可以用out去连接in吗？
    
63.                 Read r = new Read(in);
    
64.                 Write w = new Write(out);
    
65.                 new Thread(r).start();
    
66.                 new Thread(w).start();       
    
67.         }
    
68. }
    

复制代码