Java 中 ConcurrentHashMap 和 HashMap 的问题

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 2208 天前的主题，其中的信息可能已经有所发展或是发生改变。

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

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

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

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

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

map

进度

任务

hashmap

13 条回复 • 2018-12-14 11:10:12 +08:00

11wangyaoda

2018-12-12 21:44:26 +08:00

照理说 Java 8 CHM 的 Node 都是 volatile 的。可见性应该没啥问题啊。

wdlth

2018-12-12 21:46:22 +08:00

用 AtomicInteger 呢？

sagaxu

2018-12-12 21:48:32 +08:00 via Android

没看明白 index 是个什么东西，又如何 index+1

misaka19000

2018-12-12 22:05:18 +08:00

上代码，你这样讲会有些遗漏的部分，不够完整

hwding

2018-12-13 08:58:50 +08:00 via iPhone

会不会因为锁偏向的原因 get 一直获得锁然后值就写不进去？

shanigan

2018-12-13 09:05:38 +08:00

map 都是 key value pair，为什么会有 index。你每次都 index+1，key 不都改变了？结果 value 肯定都是 0

Kaiv2

2018-12-13 09:56:04 +08:00

map.get(批次号).get(index)，index + 1 ? 还能取到数据？

Luckyray

2018-12-13 10:14:28 +08:00

我错了...是语言描述能力太捉鸡了么，写一段伪代码：
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

Kaiv2

2018-12-13 10:23:11 +08:00

innerMap.put("success",innerMap.get("success")+1) 换成 AtomicInteger.incrementAndGet() 试试

misaka19000

2018-12-13 10:32:45 +08:00

innerMap.put("success",innerMap.get("success")+1)

这一行不是线程安全的