dataqueue.java

短信发送

/**
 * Created at Nov 30, 2008
 */
package com.jdev.app.db.queue;

import java.util.LinkedList;

/**
 * <p>Title: DataQueue</p>
 * <p>Description: </p>
 * @author Lawrence
 * @version 1.0
 */
public class DataQueue {
	private final static String module = DataQueue.class.getName();

	private LinkedList<Object> pool = new LinkedList<Object>();

	public int getRecordCount(){
		int count = 0;
		synchronized(pool){
			count = pool.size();
		}
		return count;
	}
	
	public void pushData(Object data) {
		synchronized (pool) {
			pool.add(data);
			pool.notifyAll();
		}

	}

	public Object removeDataFirst() {
		synchronized (pool) {
			// 如果没有任务，就锁定在这里
			while (pool.isEmpty()) {
				try {
					pool.wait(); //等待解锁
				} catch (InterruptedException ie) {
					ie.printStackTrace();
				}
			}
			return pool.removeFirst();
		}
	}
	
}