datapool.java~14~

短信网关发送接受平台。

package Utilities;
import java.util.*;
import Config;
/**
 * <p>Title: sms_statistics</p>
 * <p>Description: InHand XMLCenter 短信服务平台计费统计程序</p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: 北京映翰通网络技术有限公司</p>
 * @author 韩传俊 [e-mail]
 * @version 1.0
 */

public class DataPool {
        private Vector pipe;
        private int capacity;
        private int size;
        public boolean has_elements=false;

        public DataPool() {
                pipe=new Vector();
                this.size=0;
                this.capacity=100;
        }

        public DataPool(int capacity){
                pipe=new Vector();
                this.capacity=capacity;
                this.size=0;
        }

        public int getSize(){
                return this.size;
        }

        public boolean isFull(){
                if (this.capacity>this.size)
                        return false;
                else
                        return true;
        }

        public boolean isEmpty(){
                if (this.size==0)
                        return true;
                else
                        return false;
        }

        public synchronized boolean push(Object o){
               while(this.size==this.capacity){
                        try{
                                wait();
                        }catch(Exception e){
                                e.printStackTrace();
                        }
                }
                this.pipe.addElement(o);
                this.size++;
                try{
                        notifyAll();
                }catch(Exception e){
                        e.printStackTrace();
                }
                //this.has_elements=true;
                return true;
/*
                if (this.size<this.capacity){
                        this.pipe.addElement(o);
                        this.size++;
                        return true;
                }else{
                        return false;
                }
*/        }

        public synchronized Object pop(){
               //System.out.println("===========pop==========");
                //if (this.has_elements){
                        while(this.size<=0){
                                try{
                                        //if(this.has_elements){
                                                //System.out.println("wait");
                                                wait();
                                                //System.out.println("wake");
                                        //}
                                }catch(Exception e){
                                        e.printStackTrace();
                                }
                        }
                //}

                Object result=null;

                if (this.size>0){
                        result=this.pipe.get(0);
                        this.pipe.remove(0);
                        this.size--;
                }
                try{
                        notifyAll();
                }catch(Exception e){
                        e.printStackTrace();
                }
                return result;
/*
                Object result=null;

                if (this.size>0){

                        result=this.pipe.get(0);
                        this.pipe.remove(0);
                        this.size--;
                }
                return result;
*/          }

        public void release(){
                this.pipe.removeAllElements();
                this.pipe=null;
        }

        public static void main(String[] args) {
               // DataPool dataPool1 = new DataPool();
        }


}