java缓存数据同步问题

Question

最近在做一个简单的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解决了这个问题。有需要的我再贴代码上来吧~谢谢各位了

Answer 1

volatile来标识你的缓存，这个你的Cache在被线程改变Cache时对另外一个线程可见的。
如果你的Cache不是线程安全的，那么你可以用ReentrantLock来锁定Cache的写入