最近在做一个简单的java缓存,线程的主要功能是:查询缓存中是否存在该值,存在则返回,不存在则计算,计算完了将该键值对放到Cache里面。但是这里有个数据同步的问题,可能会有重复计算。即线程1发现不存在该值,去计算,线程2访问同一数据随后也发现不存在该值,去计算。这样就会出现重复计算,请问有没啥办法避免。谢谢大家了!
public void run() {
Long result = null;
InputMsg msg = new InputMsg(num,id);
//先查看该msg的值是否有存在缓存中,有则输出值并返回。
if(cache.containsKey(msg)){
System.out.println("cache:"+" "+cache.get(msg));
return;
}
//由于没有缓冲值,则绪按输入规则计算。
result = calculate(msg.getId());
//计算成功之后,还要看是否在计算的过程中,其他线程已经把结果计算出来了,是则返回值,不修改内存,反之,则锁定缓存区,写入值,
synchronized (cache) {
if(cache.containsKey(msg)){
System.out.println("cache:"+" "+cache.get(msg));
return;
}
//若缓存已满,则按照缓存策略删除一些数据再写入
if(cache.isFull())
cache.deleteMsg();
cache.putMsg(msg, result);
System.out.println("Caculate: "+ result);
}
return;
}
最后自己用的FutureTask解决了这个问题。有需要的我再贴代码上来吧~谢谢各位了