我决定比较处理并行和非并行流的速度,但是为了验证测试的正确性,我对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次运行应该得到几乎相同的结果。