遇到这么一个问题,后台多线程执行一个长时间的大量的任务,前台通过轮训查询任务进度。
任务进度放在一个 ConcurrentHashMap 中,然后每个线程执行完一次任务就在这个 map 里面的 index+1。然后这个 map 再放在另一个静态的 ConcurrentHashMap 里面,key 是批次号。
然后前台查询任务进度的时候是这样:静态的 map.get(批次号).get(index)得到已经完成的任务数。
也就是说外面那个 map 存储的是里面 map 的引用,然后里面 map 的内容一直在变化。但是前端查询进度的时候,得到的数字一直是 0。
外面 map 换成 HashMap 之后问题消失,有点好奇这里是不是跟 ConcurrentHashMap 的特性有关?是不是存储引用的时候会保存一个副本之类的?
1
11wangyaoda 2018-12-12 21:44:26 +08:00 1
照理说 Java 8 CHM 的 Node 都是 volatile 的。可见性应该没啥问题啊。
|
2
wdlth 2018-12-12 21:46:22 +08:00
用 AtomicInteger 呢?
|
3
sagaxu 2018-12-12 21:48:32 +08:00 via Android
没看明白 index 是个什么东西,又如何 index+1
|
4
misaka19000 2018-12-12 22:05:18 +08:00
上代码,你这样讲会有些遗漏的部分,不够完整
|
5
hwding 2018-12-13 08:58:50 +08:00 via iPhone
会不会因为锁偏向的原因 get 一直获得锁然后值就写不进去?
|
6
shanigan 2018-12-13 09:05:38 +08:00
map 都是 key value pair,为什么会有 index。你每次都 index+1,key 不都改变了?结果 value 肯定都是 0
|
7
Kaiv2 2018-12-13 09:56:04 +08:00
map.get(批次号).get(index),index + 1 ? 还能取到数据?
|
8
Luckyray OP 我错了...是语言描述能力太捉鸡了么,写一段伪代码:
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 2018-12-13 10:23:11 +08:00 1
innerMap.put("success",innerMap.get("success")+1) 换成 AtomicInteger.incrementAndGet() 试试
|
10
misaka19000 2018-12-13 10:32:45 +08:00 2
innerMap.put("success",innerMap.get("success")+1)
这一行不是线程安全的 |
11
cyspy 2018-12-13 11:09:39 +08:00 1
不想用 AtomicInteger 的话可以考虑用 merge
|
12
GreatEscape 2018-12-13 11:41:11 +08:00 1
提供个思路,batchNum 是不是有问题,为 Null ?
CHM 是不允许 Null Key 的,但是 HashMap 允许。 |
13
lilyblooper 2018-12-14 11:10:12 +08:00
innerMap.get("success")+1 这个不是 thread-safe 的。
换成 atomic* 类 |