producerconsumer.java

经典的java语言分析器

/*
 * Copyright © 2002 Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
 * California 95054, U.S.A. All rights reserved.  Sun Microsystems, Inc. has
 * intellectual property rights relating to technology embodied in the product
 * that is described in this document. In particular, and without limitation,
 * these intellectual property rights may include one or more of the U.S.
 * patents listed at http://www.sun.com/patents and one or more additional
 * patents or pending patent applications in the U.S. and in other countries.
 * U.S. Government Rights - Commercial software. Government users are subject
 * to the Sun Microsystems, Inc. standard license agreement and applicable
 * provisions of the FAR and its supplements.  Use is subject to license terms.
 * Sun,  Sun Microsystems,  the Sun logo and  Java are trademarks or registered
 * trademarks of Sun Microsystems, Inc. in the U.S. and other countries.  This
 * product is covered and controlled by U.S. Export Control laws and may be
 * subject to the export or import laws in other countries.  Nuclear, missile,
 * chemical biological weapons or nuclear maritime end uses or end users,
 * whether direct or indirect, are strictly prohibited.  Export or reexport
 * to countries subject to U.S. embargo or to entities identified on U.S.
 * export exclusion lists, including, but not limited to, the denied persons
 * and specially designated nationals lists is strictly prohibited.
 */


public class ProducerConsumer {

  /**
   * A single producer-consumer instance that is used by others.
   */
  public static ProducerConsumer pc = new ProducerConsumer();

  /**
   * The data structure where the tokens are stored.
   */
  private java.util.Vector queue = new java.util.Vector();

  /**
   * The producer calls this method to add a new token
   * whenever it is available.
   */
  synchronized public void addToken(Token token) {
    queue.addElement(token);
    notify();
  }

  /**
   * The consumer calls this method to get the next token
   * in the queue.  If the queue is empty, this method
   * blocks until a token becomes available.
   */
  synchronized public Token getToken() {
    if (queue.size() == 0) {
      try {
        wait();
      } catch (InterruptedException willNotHappen) {
        throw new Error();
      }
    }
    Token retval = (Token)(queue.elementAt(0));
    queue.removeElementAt(0);
    return retval;
  }

}