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 谢谢你的回答!
2 年多之前 回复
wojiushiwo945you
wojiushiwo945you   Ds   Rxr 2016.03.27 17:36

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

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

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

w172087242
w172087242 回复zxx20145: 你可以ReentrantLock来锁定,也可以专门一根写线程来维护
2 年多之前 回复
zxx20145
zxx20145 还是觉得不行。关键是在计算的时候会有耗时,但是在可能写之前,读操作已经发生了。然后计算计算。你可以看一下我贴的代码
2 年多之前 回复
zxx20145
zxx20145 谢谢
2 年多之前 回复
zxx20145
zxx20145 我查查它的用法。
2 年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
java缓存的问题
在长期使用中观察到,java程序运行时,会把一些jar文件解压到特定的目录下,我称之为缓存, 当我修改jar文件后,这些缓存文件不会马上跟着改变,导致产生很多难以理解的错误。   比如: Roxar tempest 的缓存会放在 C:\Users\zzx\AppData\Local\VirtualStore\Program Files\Roxar\simulation   landmark 500
java缓存问题
 摘要: 在软件开发中,我们经常面临着处理长时间任务的多线程编程问题。在我们的ezOne平台的开发中就多处涉及到,如JPC数据服务JPC数据处理服务 报警联动 门禁系统等。本人在编写DEMO程序的过程中几易其稿,煞费心机,但依然感觉有许多地方需要改进,为了减少多线程编程带来的风险,我翻译整理了一个类似问题的解决方案框架以达到一劳永逸。 为了便于阅读,保留原文。引用请保留作者和文章来源。    要害
java缓存
缓存可分为二大类: 一、通过文件缓存,顾名思义文件缓存是指把数据存储在磁盘上,不管你是以XML格式,序列化文件DAT格式还是其它文件格式;  二、内存缓存,也就是实现一个类中静态Map,对这个Map进行常规的增删查. 下面为一个简单的缓存代码
JAVA缓存
JAVA缓存有两种: 一、文件缓存,是指把数据存储在磁盘上,可以XML格式,也可以序列化文件DAT格式还是其它文件格式。 二、内存缓存,也就是实现一个类中静态Map,对这个Map进行常规的增删查。 其代码如下: 目录 [隐藏] 1 Cache类 2 CacheManager类  JAVA缓存-Cache类        public class Cache { pr
JAVA缓存的问题和OSGi机制
在长期使用中观察到,java程序运行时,会把一些jar文件解压到特定的目录下,我称之为缓存, 当我修改jar文件后,这些缓存文件不会马上跟着改变,导致产生很多难以理解的错误。 比如: Roxar tempest 的缓存会放在 C:\Users\zzx\AppData\Local\VirtualStore\ProgramFiles\Roxar\simulation landmark 500...
Java缓存
JAVA缓存有两种: 一、文件缓存,是指把数据存储在磁盘上,可以XML格式,也可以序列化文件DAT格式还是其它文件格式。 二、内存缓存,也就是实现一个类中静态Map,对这个Map进行常规的增删查。 其代码如下: 目录 [隐藏] 1 Cache类 2 CacheManager类  JAVA缓存-Cache类        public class Cache { pr
数据同步的问题
-
数据同步问题
今天碰到一个很令人头痛的问题:两个用户把数据load到本地后,第一个用户修改了密码字段,保存到数据库。然后,第二个用户又修改了同一条记录的姓名字段,由于第二个用户的密码字段没来得及刷新,保存到数据库后,把第一个用户修改的密码字段覆盖了。(修改语句是update table set name=*,pwd=* where id=x)。由于脏数据的问题,多个用户同时修改的时候,经常会发生数据相互
多服务器数据同步问题
多服务器并发的操作同一个数据库的同一张表。 有如下一张表: /* Table: APP_TASK */ TASKNO VARCHAR2(22) not null, TASK_TYPE VARCHAR2(2) not null, EXECUTE_TIME DATE, PARMAS_XML VARCHAR2(2000), STATUS VARCHAR2(1)
游戏数据同步问题
异步,而且,其实网游的数据库交互并不是特别平凡,一般来说,在首次载入数据之后,剩下的就是玩家的登录和角色选择要访问数据库了,然后还有一个就是在游戏过程中定时保存角色数据,在玩家下线后再保存一下。 其他的服务器的数据(比如城主换了,比如玩家仓库物品和包裹的物品,至于掉在地上的物品一般来说都不会保存),一般来说也是定时保存。 仅此而已。 1. 同步操作数据库,有网络消息到来,查询数据库,等查询操