1. /*编写两个线程子类，分别用来创建管道输出流和管道输入流，
   
2. 其中管道输出流向管道发送5个0~20之间的随机整数；
   
3. 管道输入流接收管道中传过来的5个随机整数，并求他们的和。
   
4. 编写Java应用程序测试管道流的数据传送。*/
   
5. 
   
6. import java.io.*;
   
7. class  PipedText
   
8. {
   
9.         public static void main(String[] args) throws Exception
   
10.         {
    
11.                 PipedInputStream pis=new PipedInputStream();
    
12.                 PipedOutputStream pos=new PipedOutputStream();
    
13.                 pos.connect(pis);
    
14.                 PipedInput pi=new PipedInput(pis);
    
15.                 PipedOutput po=new PipedOutput(pos);
    
16.                 new Thread(pi).start();
    
17.                 new Thread(po).start();
    
18.         }
    
19. }
    
20. class PipedInput implements Runnable
    
21. {
    
22.         private PipedInputStream pis;
    
23.         PipedInput(PipedInputStream pis)
    
24.         {
    
25.                 this.pis=pis;
    
26.         }
    
27.         //管道输入流接收发送过来的数，并打印它们的和
    
28.         public void run()
    
29.         {
    
30.                 try
    
31.                 {
    
32.                         byte [] buf=new byte[100];
    
33.                         int len=0;
    
34.                         int sum=0;
    
35.                         while((len=pis.read(buf))!=-1)
    
36.                         {
    
37.                                 String s=new String(buf,0,len);
    
38.                                 //System.out.println(s+"--s");
    
39.                                 int i=Integer.parseInt(s);
    
40.                                 sum+=i;
    
41.                         }
    
42.                         System.out.println(sum);
    
43.                         pis.close();
    
44.                 }
    
45.                 catch (IOException io)
    
46.                 {
    
47.                         throw new RuntimeException();
    
48.                 }
    
49.         }
    
50. }
    
51. class PipedOutput implements Runnable
    
52. {
    
53.         private PipedOutputStream pos;
    
54.         PipedOutput(PipedOutputStream pos)
    
55.         {
    
56.                 this.pos=pos;
    
57.         }
    
58.         //管道输出流发送5个0-20的随机数
    
59.         public void run()
    
60.         {
    
61.                 try
    
62.                 {
    
63.                         for (int x=0;x<5 ;x++ )
    
64.                         {
    
65.                                 int i=(int)(Math.random()*20);
    
66.                                 //System.out.println(i+"....i");
    
67.                                 String s=i+"";
    
68.                                 pos.write(s.getBytes());
    
69.                                 pos.flush();
    
70.                         }
    
71.                         pos.close();
    
72.                 }
    
73.                 catch (IOException io)
    
74.                 {
    
75.                         throw new RuntimeException();
    
76.                 }
    
77.         }
    
78. }

复制代码

最后打印结果总是不对，如果不注释掉了中间的两个打印语句，就能打印出正确结果，应该数据都存到缓冲区里了，然后一次都读出来了，有什么解决办法只打印最后结果，能不能再帮忙优化一下代码。

1. /*编写两个线程子类，分别用来创建管道输出流和管道输入流，
   
2. 其中管道输出流向管道发送5个0~20之间的随机整数；
   
3. 管道输入流接收管道中传过来的5个随机整数，并求他们的和。
   
4. 编写Java应用程序测试管道流的数据传送。*/
   
5. 
   
6. import java.io.*;
   
7. class  PipedText
   
8. {
   
9.         public static void main(String[] args) throws Exception
   
10.         {
    
11.                 PipedInputStream pis=new PipedInputStream();
    
12.                 PipedOutputStream pos=new PipedOutputStream();
    
13.                 pos.connect(pis);
    
14.                 PipedInput pi=new PipedInput(pis);
    
15.                 PipedOutput po=new PipedOutput(pos);
    
16.                 new Thread(pi).start();
    
17.                 new Thread(po).start();
    
18.         }
    
19. }
    
20. class PipedInput implements Runnable
    
21. {
    
22.         private PipedInputStream pis;
    
23.         PipedInput(PipedInputStream pis)
    
24.         {
    
25.                 this.pis=pis;
    
26.         }
    
27.         //管道输入流接收发送过来的数，并打印它们的和
    
28.         public void run()
    
29.         {
    
30.                 try
    
31.                 {
    
32.                         byte [] buf=new byte[100];
    
33.                         int len=0;
    
34.                         int sum=0;
    
35.                         while((len=pis.read(buf))!=-1)
    
36.                         {
    
37.                                 String s=new String(buf,0,len);
    
38.                                 //System.out.println(s+"--s");
    
39.                                 int i=Integer.parseInt(s);
    
40.                                 sum+=i;
    
41.                         }
    
42.                         System.out.println(sum);
    
43.                         pis.close();
    
44.                 }
    
45.                 catch (IOException io)
    
46.                 {
    
47.                         throw new RuntimeException();
    
48.                 }
    
49.         }
    
50. }
    
51. class PipedOutput implements Runnable
    
52. {
    
53.         private PipedOutputStream pos;
    
54.         PipedOutput(PipedOutputStream pos)
    
55.         {
    
56.                 this.pos=pos;
    
57.         }
    
58.         //管道输出流发送5个0-20的随机数
    
59.         public void run()
    
60.         {
    
61.                 try
    
62.                 {
    
63.                         for (int x=0;x<5 ;x++ )
    
64.                         {
    
65.                                 int i=(int)(Math.random()*20);
    
66.                                 //System.out.println(i+"....i");
    
67.                                 String s=i+"";
    
68.                                 pos.write(s.getBytes());
    
69.                                 pos.flush();
    
70.                         }
    
71.                         pos.close();
    
72.                 }
    
73.                 catch (IOException io)
    
74.                 {
    
75.                         throw new RuntimeException();
    
76.                 }
    
77.         }
    
78. }

复制代码

最后打印结果总是不对，如果不注释掉了中间的两个打印语句，就能打印出正确结果，应该数据都存到缓冲区里了，然后一次都读出来了，有什么解决办法只打印最后结果，能不能再帮忙优化一下代码。