tworobots.java

对话

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

class AA extends Thread {
  private Random rand = new Random();
  private PipedWriter aaout = new PipedWriter();
  private PipedReader aain;              
  public 	PipedWriter getPipedWriter() { return aaout; }
  public void run() {
		    while(true) {
		      for(char c = 'A'; c <= 'Z'; c++) {
		        try {
		          aaout.write(c);
		          sleep(rand.nextInt(500));
		          System.out.println("Yang say ascall: " + (int)c);	
		        } catch(Exception e) {
		          throw new RuntimeException(e);
		        }
      	}
   		}
 		}
}

class BB extends Thread {
  private PipedReader bbin;
  private PipedWriter bbout;
  public PipedWriter getPipedWriter() { return bbout; }
  char bbc='a';
  public BB(AA sender) throws IOException {
    bbin = new PipedReader(sender.getPipedWriter());
  }
  public void run() {
		    try {
		    	
		      while(true) {
		        bbc=(char)bbin.read();
		        System.out.println("Duan say char: " + bbc);
		      }
		    } catch(IOException e) {
		      throw new RuntimeException(e);
		    }
		}
}

class TwoRobots {
  public static void main(String[] args) throws Exception {
    AA sender = new AA();
    BB receiver = new BB(sender);
    sender.start();
    receiver.start();
    receiver.join(10);
  }
}