queue.java

天乙社区6.0是一套基于JAVA技术的网络虚拟社区

package com.laoer.bbscs.sys;

import java.io.Serializable;
import java.util.Vector;

/**
 * <p>Title: TianYi BBS</p>
 * <p>Description: TianYi BBS System</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: LAOER.COM/TIANYISOFT.NET</p>
 * @author laoer
 * @version 6.0
 */

public class Queue
    implements Serializable {

  private Vector aVector;

  public Queue() {
    aVector = new Vector();
  }

  public Queue(Vector aVector) {
    aVector = aVector;
  }

  /**
   * Add a object into Queue
   * @param o Object
   */
  public synchronized void add(Object o) {
    aVector.add(o);
  }

  /**
   * Get Object from Queue
   * @return Object
   */
  public synchronized Object get() {
    if (isEmpty()) {
      return null;
    }
    Object o = aVector.elementAt(0);
    aVector.removeElementAt(0);
    return o;
  }

  public boolean isEmpty() {
    return aVector.isEmpty();
  }

  public synchronized void clear() {
    aVector.removeAllElements();
  }

  public int search(Object o) {
    return aVector.indexOf(o);
  }

  public synchronized int size() {
    return aVector.size();
  }

}