mtcache.java

来自「短信系统SMS：支持普通短信、长短信和wap push短信的发送。」· Java 代码 · 共 68 行

package com.ekun.biz.sms;

import java.util.*;
import com.ekun.common.sms.SmsInfo;
import com.ekun.biz.vo.MtVO;
import com.ekun.biz.dao.MtDAO;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author ekun
 * @version 1.0
 */
public class MtCache implements Runnable
{
  private Vector vctMt = new Vector();
  private static MtCache instance = new MtCache();;
  private boolean allowRun = true;

  private MtCache()
  {
  }

  public static MtCache getInstance()
  {
    return instance;
  }
  public void put(SmsInfo smsInfo)
  {
    synchronized(vctMt)
    {
      MtVO vo = new MtVO();
      vo.setDBMSGID(smsInfo.DBMsgID);
      vo.setRESULT(smsInfo.SendResult);
      vo.setRESULTDESC(smsInfo.ErrorDesc);
      vo.setSMSMSG_ID(smsInfo.SMSMsgID);
      vctMt.add(vo);
    }
  }

  public void run()
  {
    MtVO vos[];
    MtDAO dao = new MtDAO();
    while(allowRun)
    {
      try{ Thread.currentThread().sleep(500);} catch(Exception ex){}

      synchronized(vctMt)
      {
        vos = (MtVO[]) vctMt.toArray(new MtVO[0]);
        vctMt.clear();
      }
      dao.batchInsert(vos);
    }
  }

  public static void main(String[] args)
  {
    MtCache submitcache = new MtCache();
  }
}