我决定比较处理并行和非并行流的速度,但是为了验证测试的正确性,我对2个并行流进行了测试,结果似乎是错误的:第一个流大约需要60000000纳秒,而仅次于2500万

您能否解释一下我该如何确定尺寸?
我在下面提供了一个已编译的方法,因此问题不是编译器优化的问题。

static void streamSpeed() {
    int[] numbers = new int[1000];

    for(int i = 0; i < 1000; numbers[i] = i++) {
        ;
    }

    long gap_2 = 0L;
    long start = System.nanoTime();
    List<Double> doubles_1 = (List)Arrays.stream(numbers).parallel().peek((ix) -> {
        System.out.print(ix + ", ");
    }).mapToDouble((ix) -> {
        return (double)ix;
    }).boxed().collect(Collectors.toList());
    long gap_1 = System.nanoTime() - start;
    System.out.println();
    start = System.nanoTime();
    List<Double> doubles_2 = (List)Arrays.stream(numbers).parallel().peek((ix) -> {
        System.out.print(ix + ", ");
    }).mapToDouble((ix) -> {
        return (double)ix;
    }).boxed().collect(Collectors.toList());
    gap_2 = System.nanoTime() - start;
    System.out.println();
    System.out.println("Gap_1 : " + gap_1);
    System.out.println("Gap_2 : " + gap_2);
    doubles_1.forEach((ix) -> {
        System.out.print(ix + ", ");
    });
}

最佳答案

已经以略有不同的方式提出了这个问题。请看一下这篇文章:

Java8 stream operations are cached?

第一次运行需要更长的时间,因为必须第一次加载所有类和依赖项。如果您将测试扩展到10次运行,那么2至10次运行应该得到几乎相同的结果。

10-04 11:45