关于管道流实现线程间通信的问题，大家帮忙举个具有实战的例子。要有源代码哦。

1. package cn.study.io;
   
2. 
   
3. 
   
4. import java.io.IOException;
   
5. import java.io.PipedInputStream;
   
6. import java.io.PipedOutputStream;
   
7. 
   
8. public class PipedStreamDemo {
   
9. 
   
10.         /**
    
11.          * @param args
    
12.          * @throws IOException
    
13.          */
    
14.         public static void main(String[] args) throws IOException {
    
15.                 // TODO Auto-generated method stub
    
16. 
    
17.                 final PipedInputStream pis = new PipedInputStream();
    
18.                 final PipedOutputStream pos = new PipedOutputStream();
    
19.                
    
20.                 Thread read = new Thread(){
    
21.                         public void run(){
    
22.                                 try {
    
23.                                         byte[] buf = new byte[1024];
    
24.                                         System.out.println("读取前,没有数据,等待...");
    
25.                                         int len = pis.read(buf);
    
26.                                         System.out.println("读到数据,打印数据...");
    
27.                                         String str = new String(buf,0,len);
    
28.                                         System.out.println(str);
    
29.                                         pis.close();
    
30.                                 } catch (IOException e) {
    
31.                                         // TODO Auto-generated catch block
    
32.                                         e.printStackTrace();
    
33.                                 }
    
34.                         }
    
35.                 };
    
36.                
    
37.                 Runnable write = new Runnable(){
    
38.                         public void run(){
    
39.                                 try {
    
40.                                         System.out.println("开始写入数据,等待6秒后...");
    
41.                                         Thread.sleep(6000);
    
42.                                         pos.write("piped lai la".getBytes());
    
43.                                         pos.close();
    
44.                                 } catch (Exception e) {
    
45.                                         // TODO Auto-generated catch block
    
46.                                         e.printStackTrace();
    
47.                                 }
    
48.                         }
    
49.                 };
    
50.                 pis.connect(pos);
    
51.                 read.start();
    
52.                 new Thread(write).start();               
    
53.         }
    
54. }

复制代码