1. package cn.itcast.io;
   
2. 
   
3. import java.io.IOException;
   
4. import java.io.PipedInputStream;
   
5. import java.io.PipedOutputStream;
   
6. import java.util.concurrent.ExecutorService;
   
7. import java.util.concurrent.Executors;
   
8. 
   
9. public class PipedDemo {
   
10.         
    
11.         public static void main(String[] args) throws Exception {
    
12.         
    
13.         final PipedOutputStream pipeout = new PipedOutputStream();
    
14.         final PipedInputStream pipein = new PipedInputStream(pipeout);
    
15.         
    
16.         
    
17.         ExecutorService pool = Executors.newCachedThreadPool();
    
18.         
    
19.         pool.execute(new Runnable(){
    
20.                 @Override
    
21.                 public void run() {
    
22.                         try {                                
    
23.                                 pipeout.write("hello motou".getBytes());
    
24.                                 pipeout.close();
    
25.                         } catch (IOException e) {
    
26.                                 throw new RuntimeException("shuchushibai");
    
27.                         }
    
28.                         System.out.println(Thread.currentThread());
    
29.                 }               
    
30.         });
    
31.         pool.execute(new Runnable(){
    
32. 
    
33.                 @Override
    
34.                 public void run() {
    
35.                         
    
36.                         try {
    
37.                                 
    
38.                                 byte[] bit = new byte[1024];
    
39.                                 int len = pipein.read(bit);
    
40.                                 System.out.println(new String(bit,0,len));
    
41.                                 pipein.close();
    
42.                         } catch (IOException e) {
    
43.                                 throw new RuntimeException("shurushibai");
    
44.                         }        
    
45.                         System.out.println(Thread.currentThread());
    
46.                 }               
    
47.         });
    
48.         
    
49.         }
    
50. }

复制代码

占楼 帮顶

程序大致是没哟问题的，也没有产生死锁。

进行了一个小的修改，判断是否结束


while(len!=-1)
           System.out.println(new String(bit,0,len));


|--你说的应该是程序为什么没有结束吧
   因为你创建的是一个ThreadPool也就是所谓的线程池。

需要加pool.shutDown(); 或者pool.shutdownNow();


希望可以帮到你