来自哈希集中的并行流不并行运行

Question

我有要并行处理的元素集合。当我使用列表时，并行性起作用。但是，当我使用set时，它不会并行运行。

public static void main(String[] args) {
    ParallelTest test = new ParallelTest();

    List<Integer> list = Arrays.asList(1,2);
    Set<Integer> set = new HashSet<>(list);

    ForkJoinPool forkJoinPool = new ForkJoinPool(4);

    System.out.println("set print");
    try {
        forkJoinPool.submit(() ->
            set.parallelStream().forEach(test::print)
        ).get();
    } catch (Exception e) {
        return;
    }

    System.out.println("\n\nlist print");
    try {
        forkJoinPool.submit(() ->
            list.parallelStream().forEach(test::print)
        ).get();
    } catch (Exception e) {
        return;
    }   
}

private void print(int i){
    System.out.println("start: " + i);
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
    }
    System.out.println("end: " + i);
}

set print
start: 1
end: 1
start: 2
end: 2

list print
start: 2
start: 1
end: 1
end: 2

Answer 1

我可以再现您看到的行为，其中的并行性与您指定的fork-join池并行性不匹配。在将fork-join池的并行度设置为10并将集合中的元素数增加到50之后，我看到基于列表的流的并行度仅上升到6，而基于集的流的并行度从未超过2。

但是，请注意，这种将任务提交到fork-join池以运行该池中的并行流的技术是一种实现“技巧”，并不保证能够工作。实际上，用于执行并行流的线程或线程池是未指定的。默认情况下，使用公共fork-join池，但在不同的环境中，最终可能使用不同的线程池。（考虑应用程序服务器中的容器。）

在java.util.Stream.AbstractTask类中，leaf_target字段决定了所做的拆分量，而拆分量又决定了可以实现的并行度。该字段的值基于forkJoinPool.getCommonPoolParallelism()，它当然使用公共池的并行性，而不是运行任务的任何池。

System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "10");

再说一遍，这不是有保证的行为，将来可能会改变。但在可预见的将来,这种技术可能适用于JDK8实现。

更新2019-06-12:JDK-8190974在JDK 10中已被修复，该修复程序已被备份到即将发布的JDK 8u版本(8u222)。