queue_socket.java

福建鑫诺话机客户端接受程序

package telproject;

import java.util.Vector;

/**
 * 队列
 */
public class Queue_Socket {

	private Vector vctData = null;

	private int iMaxSize = 0;

	public Queue_Socket() {
		iMaxSize = Integer.MAX_VALUE;
		vctData = new Vector();
	}

	public Queue_Socket(int size) {
		iMaxSize = Integer.MAX_VALUE;
		vctData = new Vector();
	}

	public synchronized int push(Object ms) {
		if (vctData.size() > iMaxSize) {
			return -1;
		}
		try {
			vctData.addElement(ms);
			return 0;
		} catch (Exception e) {
			e.printStackTrace();
		}
		return 1;
	}

	public synchronized Object pop() {
		Object o = null;
		if (vctData.isEmpty()) {
			return null;
		}
		o = vctData.elementAt(0);
		vctData.removeElementAt(0);
		return o;
	}

	public synchronized Object get(int i) {
		if (i >= size()) {
			return null;
		}
		try {
			return vctData.elementAt(i);
		} catch (Exception e) {
		}
		return null;
	}

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

	public synchronized int remove(int i) {
		try {
			vctData.removeElementAt(i);
			return i;
		} catch (Exception e) {
		}
		return -1;
	}

	public synchronized int remove(Object obj) {
		if (obj == null) {
			return 0;
		}
		Object o = null;
		int iDel = 0;
		for (int i = 0; i < vctData.size(); i++) {
			try {
				o = vctData.elementAt(i);
				if (o == obj) {
					vctData.removeElementAt(i);
					i--;
					iDel++;
				}
			} catch (Exception e) {
			}
		}
		// System.out.println("--------Delete Num="+iDel);
		return iDel;
	}

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