【发布时间】:2015-04-13 22:06:26
【问题描述】:
在Java8中,计算ConcurrentHashMap中的数据后,
// this is a working code, which I want to simplify
ConcurrentMap<String, AtomicInteger> data =
new ConcurrentHashMap<String, AtomicInteger>();
// ... (fill in the data object)
final int l = data.keySet().size();
P[] points = new P[l];
int i = 0;
for (Map.Entry<String, AtomicInteger> entry : data.entrySet())
points[i++] = new A(entry.getKey(), entry.getValue().get() * 1.0 / 105);
Arrays.sort(points);
我想实现这个:
data.parallelStream()
.map( (k, v) -> new A(k, v.get() * 1.0 / 105) )
.sort().forEach(System.out::println)
如何正确地做到这一点?
【问题讨论】:
-
您可能应该检查在已经并发的 Map 实现中是否真的需要 AtomicInteger 作为值类型。
标签: java parallel-processing java-8 java-stream concurrenthashmap