cmpp2login.java

java支持的短信平台

package com.khan.sms.cmpp2control;


import com.khan.sms.*;
import com.khan.util.*;
import com.khan.socket.SocketPoolCon;


/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class Cmpp2Login implements Runnable {
    static boolean flag = true;
    static boolean connected = false;
    CmppParam cp = CmppParam.getInstance();
    RecvQueue rq = RecvQueue.getInstance();

    public Cmpp2Login() {
        common.Assert("debug:cmpp2login线程建立!");
    }

    public static void stopThread() {
        flag = false;
    }



    public void run() {
        common.Assert("debug:"+Thread.currentThread().getName()+"线程运行!");
        while (flag) {
            try {
                SocketPoolCon spc = null;
                if (!connected) {
                    common.Assert("debug:"+Thread.currentThread().getName()+" 连接断开!");
                    cp.Cmpp_Socket.clearCon();
                    try{
                        spc = cp.Cmpp_Socket.get();
                    }finally{
                        if(null != spc) {
                            connected =true;
                            cp.Cmpp_Socket.release(spc);
                            //spc = null;
                        }
                    }
                }

                common.sleep(cp.SEND_SLEEP);

            } catch (NullPointerException e) {
                e.printStackTrace();
            }

        }
        common.Assert("debug:"+Thread.currentThread().getName()+"线程停止!");
    }

    protected void finalize() {
        common.Assert("debug:"+Thread.currentThread().getName()+" 线程释放!");
    }
}