java - 为什么使流并行导致IndexOutOfBoundsException而不是仅产生顺序不同的输出[duplicate]

Question

This question already has an answer here:

How does reduce() method work with parallel streams in Java 8?
                                
                                    （1个答案）
                                
                        
                                3个月前关闭。
            
                    
下面的代码工作并产生一个String，该字符串是从1开始连接前100个unicode字符的结果。[我正在使用Java 1.8版本]

Stream<Character> chars = Stream.iterate('1', op -> (char)(op + 1));
        StringBuilder value = chars.limit(100).reduce
                (new StringBuilder(""), (s, c) -> s.append(c), (p,d) -> p.append(d) );
        System.out.println(value.toString());

上面的输出是-

123456789：； <=>？@ ABCDEFGHIJKLMNOPQRSTUVWXYZ [] ^ _`abcdefghijklmnopqrstuvwxyz {|}〜?????????????????????

但是，当我按如下所示使chars成为并行流时，我得到了IndexOutOfBoundsException-

        Stream<Character> chars = Stream.iterate('1', op -> (char)(op + 1));
        StringBuilder value = chars.parallel().limit(100).reduce
                (new StringBuilder(""), (s, c) -> s.append(c), (p,d) -> p.append(d) );
        System.out.println(value.toString());

我期望值字符串中字符的顺序会有所不同，因为这是并行流，但是即使顺序无关紧要，该程序也可以用于并行流。但是我收到了IndexOutOfBoundsException。如果使流并行，为什么会出现IndexOutOfBoundsException。

最佳答案

这是因为数组的长度和并行流的功能。并行流将数组分成多个块，然后将它们发送到cpu的不同内核中进行处理。这是预期发生这种异常的地方。

并且您可以发布异常跟踪。

关于java - 为什么使流并行导致IndexOutOfBoundsException而不是仅产生顺序不同的输出[duplicate]，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/58104826/

上一篇：java - 使用 Apache Commons 和 Java FTP 下载后无法打开 Word 文档

下一篇：java - 为什么我的代码没有通过 IllegalArgumentException 的 JUnit 测试？

Answer 1

这是因为数组的长度和并行流的功能。并行流将数组分成多个块，然后将它们发送到cpu的不同内核中进行处理。这是预期发生这种异常的地方。

并且您可以发布异常跟踪。