receiver.java

这是孙卫琴在"Java与面向对象编程"一书的源代码。

import java.io.*;
import java.util.*;

/** 向管道输出流写数据的线程 */
class Sender extends Thread{
 private PipedOutputStream out=new PipedOutputStream();
 public PipedOutputStream getPipedOutputStream(){return out;}

 public void run(){
   try{
     for(int i=-127;i<=128;i++){
      out.write(i);
      yield();
     }
     out.close();
   }catch(Exception e){throw new RuntimeException(e);}
 }
}

/** 从管道输入流读数据的线程 */
public class Receiver extends Thread{
 private PipedInputStream in;
 public Receiver(Sender sender)throws IOException{
   in=new PipedInputStream(sender.getPipedOutputStream());
 }

 public void run(){
  try{
    int data;
    while((data=in.read())!=-1)
      System.out.println(data);
    in.close();
  }catch(Exception e){throw new RuntimeException(e);}
 }

 public static void main(String args[])throws Exception{
   Sender sender=new Sender();
   Receiver receiver=new Receiver(sender);
   sender.start();
   receiver.start();
 }
}





/****************************************************
 * 作者：孙卫琴                                     *
 * 来源：<<Java面向对象编程>>                       *
 * 技术支持网址：www.javathinker.org                *
 ***************************************************/