现在我有一个需求:


package com.message.application;
import com.sun.org.apache.xalan.internal.xsltc.runtime.Hashtable;
public class ApplicationValue {
private static Hashtable licenceKeyHashTable;
static {
System.out.println("ApplicationValue static代码块");
licenceKeyHashTable = new Hashtable();
licenceKeyHashTable.put("A", 1000000);
}
public static long getLicenKeyValue() {
long value = Long.parseLong(licenceKeyHashTable.get("A").toString());
return value;
}
public static void setLicenKeyValue(long val) {
licenceKeyHashTable.put("A", val);
}
}
?package com.message.quartz.schedule;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import com.message.application.ApplicationValue;
import com.message.application.MessageContext;
import com.message.services.interfaces.IMessageSV;
public class MessageSchedule {
private static Log log = LogFactory.getLog(MessageSchedule.class);
public void send() throws Exception {
log.info("=========================START=========================");
//log.info(arg0);
long currentVal = ApplicationValue.getLicenKeyValue();
log.info("当前线程名称:"+Thread.currentThread().getName()+":"+currentVal);
if(getModNum() == 1) {
log.info("名称为1的线程sleep3秒");
Thread.currentThread().sleep(3000);
}
ApplicationValue.setLicenKeyValue(--currentVal);
log.info("=========================END=========================");
}
public void send2() throws Exception {
log.info("=========================START=========================");
int modNum = getModNum();
IMessageSV sv = (IMessageSV) MessageContext.getBean("IMessageSV");
sv.dealMessages(modNum);
log.info("=========================END=========================");
}
public static int getModNum() {
String tName = Thread.currentThread().getName();
String modNum = tName.substring(tName.length() - 1, tName.length());
log.info(tName + "-----modNum:" + modNum);
return Integer.parseInt(modNum);
}
}
?原文:http://toknowme.iteye.com/blog/2212529