首页   注册   登录
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX  ›  Java

Java 中 ConcurrentHashMap 和 HashMap 的问题

  •  
  •   Luckyray · 285 天前 · 1596 次点击
    这是一个创建于 285 天前的主题,其中的信息可能已经有所发展或是发生改变。

    遇到这么一个问题,后台多线程执行一个长时间的大量的任务,前台通过轮训查询任务进度。

    任务进度放在一个 ConcurrentHashMap 中,然后每个线程执行完一次任务就在这个 map 里面的 index+1。然后这个 map 再放在另一个静态的 ConcurrentHashMap 里面,key 是批次号。

    然后前台查询任务进度的时候是这样:静态的 map.get(批次号).get(index)得到已经完成的任务数。

    也就是说外面那个 map 存储的是里面 map 的引用,然后里面 map 的内容一直在变化。但是前端查询进度的时候,得到的数字一直是 0。

    外面 map 换成 HashMap 之后问题消失,有点好奇这里是不是跟 ConcurrentHashMap 的特性有关?是不是存储引用的时候会保存一个副本之类的?

    13 回复  |  直到 2018-12-14 11:10:12 +08:00
        1
    11wangyaoda   285 天前   ♥ 1
    照理说 Java 8 CHM 的 Node 都是 volatile 的。可见性应该没啥问题啊。
        2
    wdlth   285 天前
    用 AtomicInteger 呢?
        3
    sagaxu   285 天前 via Android
    没看明白 index 是个什么东西,又如何 index+1
        4
    misaka19000   285 天前
    上代码,你这样讲会有些遗漏的部分,不够完整
        5
    hwding   284 天前 via iPhone
    会不会因为锁偏向的原因 get 一直获得锁然后值就写不进去?
        6
    shanigan   284 天前
    map 都是 key value pair,为什么会有 index。你每次都 index+1,key 不都改变了?结果 value 肯定都是 0
        7
    Kaiv2   284 天前
    map.get(批次号).get(index),index + 1 ? 还能取到数据?
        8
    Luckyray   284 天前
    我错了...是语言描述能力太捉鸡了么,写一段伪代码:
    class{
    ConcurrnetHashMap outerMap=new ConcurrentHashMap();

    获取任务进度的函数(){
    outerMap.get(batchNum).get("success");
    }

    任务处理的函数(){
    ConcurrentHashMap innerMap=new ConcurrentHashMap();
    innerMap.put("success",0);
    outerMap.put(batchNum,innerMap);
    foreach(task:tasks){
    ThreadPool.execute(() -> {
    innerMap.put("success",innerMap.get("success")+1)
    })
    }
    }
    }
    @Kaiv2 @shanigan @sagaxu @misaka19000
        9
    Kaiv2   284 天前   ♥ 1
    innerMap.put("success",innerMap.get("success")+1) 换成 AtomicInteger.incrementAndGet() 试试
        10
    misaka19000   284 天前   ♥ 2
    innerMap.put("success",innerMap.get("success")+1)

    这一行不是线程安全的
        11
    cyspy   284 天前   ♥ 1
    不想用 AtomicInteger 的话可以考虑用 merge
        12
    GreatEscape   284 天前   ♥ 1
    提供个思路,batchNum 是不是有问题,为 Null ?
    CHM 是不允许 Null Key 的,但是 HashMap 允许。
        13
    lilyblooper   283 天前
    innerMap.get("success")+1 这个不是 thread-safe 的。
    换成 atomic* 类
    关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   2374 人在线   最高记录 5043   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.3 · 20ms · UTC 15:22 · PVG 23:22 · LAX 08:22 · JFK 11:22
    ♥ Do have faith in what you're doing.