任务间使用管道输入输出

管道流PipedReader和PipedWriter,它不同于普通的IO流，管道基本上是一个阻塞队列，且当线程对象调用shutdownNow之后，PipedReader是可中断的，而不通的IO是不可中断的。

 

==============向管道写任务==============

public class Sender implements Runnable{

 private Random random=new Random(47);
 
 private PipedWriter out=new PipedWriter();
 
 public PipedWriter getPipedWriter(){
  return out;
 }
 
 
 
 @Override
 public void run() {
  // TODO Auto-generated method stub
  try {
   while(true){
    for(char c='A';c<='z';c++){
     out.write(c);
     System.out.println("Write:"+c);
     TimeUnit.MILLISECONDS.sleep(random.nextInt(500));
    }
   }
  } catch (IOException e) {
   // TODO Auto-generated catch block
   System.out.println("Sender writer exception");
  } catch (InterruptedException e) {
   // TODO Auto-generated catch block
   System.out.println("Sender interrupted.");
  }
  
 }
}

 

 

======================从管道读取任务

public class Receiver implements Runnable{

 private PipedReader in;
 
 public Receiver(Sender sender) {
  // TODO Auto-generated constructor stub
  try {
   in=new PipedReader(sender.getPipedWriter());
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
 @Override
 public void run() {
  // TODO Auto-generated method stub
  try {
   while(true){
    System.out.println("Read:"+(char)in.read());
   }
  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }
 
}

 

======================测试类

public class PipedIO {

 public static void main(String[] args) throws InterruptedException{
  Sender sender=new Sender();
  Receiver receiver=new Receiver(sender);
  ExecutorService exec=Executors.newCachedThreadPool();
  exec.execute(sender);
  exec.execute(receiver);
  TimeUnit.SECONDS.sleep(4);
  exec.shutdownNow();
  
 }
}

 

----------------执行结果如下：

Read:A
Write:A
Write:B
Write:C
Write:D
Write:E
Read:B
Read:C
Read:D
Read:E
Write:F
Write:G
Read:F
Read:G
Write:H
Write:I
Write:J
Write:K
Write:L
Write:M
Read:H
Read:I
Read:J
Read:K
Read:L
Read:M
Write:N
Write:O
Write:P
Write:Q
java.io.InterruptedIOException
Read:N
Read:O
Read:P
Read:Q
Sender interrupted.
 at java.io.PipedReader.read(PipedReader.java:242)
 at com.test.thread.pipe.Receiver.run(Receiver.java:24)
 at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
 at java.lang.Thread.run(Thread.java:619)