mothread.java~8~

短信网关发送接受平台。

package smscenter;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */

public class MoThread extends Engine{
    private DBConnection db = null;
    public MoThread() {
        super("MoThread");
        setDaemon(true);
        db = new DBConnection(Config.db_name ,Config.db_host );
    }
    public void run(){
        while(isRunning()){
            if(Config.moPool.getSize() >0){
                String sql = (String)Config.moPool.pop();
                db.executeUpdate(sql);
                Config.log.log("Get One Mo,Insert it the Sql is : \r\n\t"+sql);
            }
            try{
                sleep(TimeConfig.TIME_ONE_SECOND/1);
            }catch(Exception e){
                System.out.println("Exception In MoThread : "+e.toString() );
                Config.log.log("Exception In MoThread : "+e.toString());
            }
        }
    }
    public static void main(String[] args) {
        MoThread moThread1 = new MoThread();
    }
}