java - 使用并行流列表设置空值

Question

我有以下代码

final String arr[] = {"A", "B", "C", "D"};
final List<String> list1 = new ArrayList<>();
final List<String> list2 = Arrays.asList(arr).parallelStream()
                          .peek(s -> list1.add(s + s))
                          .map(s -> s + s)
                          .collect(Collectors.toList());
System.out.println(list1);
System.out.println(list2);

我得到以下结果:

[null, AA, DD, null]
[AA, BB, CC, DD]

为什么 list1 中某些元素显示 null？我知道我应该将 SynchronizedList 与 parallelStream 一起使用，但 null 值令我惊讶。一旦您将某些内容添加到列表中，就应该设置该插槽，并且下一次执行应该向其中添加另一个值。

Answer 1

ArrayList 不是一个线程安全的集合，并且您尝试使用 parallelStream 从多个线程更新它，您看到的是调整大小该ArrayList的内部数组的结果 - 该操作也不是线程安全的，您首先增加数组，然后然后将元素移动到其中:可能元素尚未移动，您尝试访问它。

为了更明确地说明，当调整大小时，会创建一个大小增加的新数组 - 如果充满null，则该新数组仅 复制发生后。

将会发生的事情确实无法预测，只是不要依赖其中任何一个。

编辑

我无法将其作为评论发布，但这里有一些代码证明可以看到 null:

List<Integer> result = IntStream.iterate(0, i -> i + 1)
            .takeWhile(i -> {
                String arr[] = { "A", "B", "C", "D", "E", "F", "G", "H", "R", "T" };
                List<String> list = new ArrayList<>();
                Arrays.stream(arr)
                        .parallel()
                        .peek(list::add)
                        .forEach(x -> {
                        });

                if (list.contains(null)) {
                    System.out.println("It took " + i + " steps to see a null");
                    return false;
                }

                return true;
            })
            .boxed()
            .collect(Collectors.toList());