这个IntStream分区实现真的不是线程安全的吗？

Question

此">答案提供了对IntStream进行分区的实现：

IntStream intStream = IntStream.iterate(0, i -> i + 1).limit(1000000);

Predicate<Integer> p = x -> r.nextBoolean();
Map<Boolean, List<Integer>> groups = intStream.collect(() -> {
    Map<Boolean, List<Integer>> map = new HashMap<>();
    map.put(false, new ArrayList<>());
    map.put(true, new ArrayList<>());
    return map;
}, (map, x) -> {
    boolean partition = p.test(x);
    List<Integer> list = map.get(partition);
    list.add(x);
}, (map1, map2) -> {
    map1.get(false).addAll(map2.get(false));
    map1.get(true).addAll(map2.get(true));
});

System.out.println(groups.get(false).size());
System.out.println(groups.get(true).size());

但是它的编辑提到这个实现不是线程安全的。然而，据我所知，收集器创建了一个单独的HashMap

顺便说一句：答案提供了一个更优雅的解决方案（Stream）

PS：我想把这个问题作为评论添加到原始帖子中，但我甚至没有声誉来添加评论…：|




Answer 1

嗯，Random是线程安全的，但是不应该以这种方式使用，因为它在争用下的性能很差，但是ArrayList不是线程安全的。使用并行流，您将调用list。从多个线程添加（x）。

Answer 2

根据神谕文献

与减少（int， IntBinaryoperator）一样，收集操作可以并行化，而无需额外的同步。

https://docs.oracle.com/javase/8/docs/api/java/util/stream/IntStream.html#collect-爪哇。util。作用供应商java。util。作用ObjIntConsumer java。util。作用双消费者-

看来你的直觉是对的，这是线程安全的。