2 zxx20145 zxx20145 于 2016.03.27 17:05 提问

java缓存数据同步问题

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

3个回答

caozhy
caozhy   Ds   Rxr 2016.03.27 17:34

synchronized(你的缓存)
{
获得值
从缓存删除这个值
}
具体代码
http://www.cnblogs.com/devinzhang/archive/2011/12/14/2287675.html

zxx20145
zxx20145 谢谢你的回答!
一年多之前 回复
wojiushiwo945you
wojiushiwo945you   Ds   Rxr 2016.03.27 17:36

缓存同步问题,主要就是使用互斥锁,保证统一时刻只能由一个线程读取判断并修正,这些操作要是原子的,所以volatile不适合。可以使用内置锁synchronized,也可以用显示所ReentrantLock。

wojiushiwo945you
wojiushiwo945you 回复zxx20145: 那你的计算操作涉及到写吗?如果有读有写,必须让这些操作都是原子完成才行啊,否则你的数据就不准确了啊。
一年多之前 回复
zxx20145
zxx20145 谢谢回答~
一年多之前 回复
zxx20145
zxx20145 我意思是它读取的时候可以加锁,但是计算就不能加锁了,加锁并行效率就太低了。但是在计算的时候不能保证不会有同样的请求进来,然后判断缓存不存在,也去计算了。
一年多之前 回复
w172087242
w172087242   Ds   Rxr 2016.03.27 17:21

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

w172087242
w172087242 回复zxx20145: 你可以ReentrantLock来锁定,也可以专门一根写线程来维护
一年多之前 回复
zxx20145
zxx20145 还是觉得不行。关键是在计算的时候会有耗时,但是在可能写之前,读操作已经发生了。然后计算计算。你可以看一下我贴的代码
一年多之前 回复
zxx20145
zxx20145 谢谢
一年多之前 回复
zxx20145
zxx20145 我查查它的用法。
一年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!