现在我有一个需求：
用户想发起一个请求，用户必须输入一个Licence Key，然后查看有没有权限访问，并且返回可用数量，然后后台有很多的线程会操作这个变量。
我本来是准备把这个变量存储在表中，根据用户输入的Licence Key去查看，但分析发现存在一个时间差的问题
就是我从数据库获取一个值，但是返回给用户的过程中，后台的很多线程还是在操作这个变量，就是因为这个时间差，导致用户获取的值
修改后的模式如下：
代码实现如下：
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);
}
}
quartz实现
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);
}
}
日志比较多，有兴趣的，可以看看附件“execute.rar”
今天的这个场景，正好再次证明我之前的文章，Hashtable是线程安全的，10个线程并发操作，
但是我对线程1，休息3秒，后续的线程都是等待线程1执行完成后再次执行，看来某钱的面试，还是有意义的~~