server2.java

提供了常用的JAVA技术的示例

package Producer;

import java.util.Vector;

public class Server2 extends Thread {
  Client2 client;
  int counter;

  public Server2(Client2 _client) {
    this.client = _client;
    this.counter = 0;
  }

  public void run() {
    try {
      while (counter < 10) {
           this.client.queue.addElement(new Integer(counter));
           counter++;
      }
      //throw new RuntimeException("counter >= 10");
    }
    catch (Exception e) {
        this.client.interruptFlag = true;
        //throw new RuntimeException(e.toString());
    }
  }

  public static void main(String[] args) {
    Client2 c = new Client2();
    Server2 s = new Server2(c);
    c.start();
    s.start();
  }
}

class Client2 extends Thread {
  Vector queue;
    boolean interruptFlag;

  public Client2() {
    this.queue = new Vector();
    this.interruptFlag = false;
  }

  public void run() {
      while (! interruptFlag) {
      if (! (queue.size() == 0)) {
        processNextElement();
      }
    }

    // Processes whatever elements remain on the queue before exiting.
    while (! (queue.size() == 0)) {
      processNextElement();
    }
    System.out.flush();
  }

  private void processNextElement() {
    Object next = queue.elementAt(0);
    queue.removeElementAt(0);
    System.out.println(next);
  }
}