src/common/web/SysQueue.java

微信扫码关注公众号，代码整理好后第一时间通知你。

package common.web;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.Iterator;

import java.util.List;

public class SysQueue implements Serializable {

	private static final long serialVersionUID = 1L;

	private List list = new ArrayList();

	private byte[] lock = new byte[0];

	public void add(Object o) {

		synchronized (lock) {
			list.add(o);
		}

	}

	public Object get() {
		synchronized (lock) {
			if (isEmpty()) {
				return null;
			} else
				return this.list.remove(0);

		}

	}

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

	public synchronized void clear() {
		list.clear();
	}

	public int size() {
		synchronized (lock) {
			return list.size();
		}
	}

	public Iterator getAll() {
		synchronized (lock) {
			return list.iterator();
		}
	}
}