【发布时间】：2014-05-04 16:44:10
【问题描述】：
我是 Java 8 的新手。我仍然不深入了解 API，但我做了一个小型的非正式基准测试来比较新 Streams API 与良好的旧 Collections 的性能。
测试包括过滤Integer 的列表，并为每个偶数计算平方根并将其存储在List 的Double 的结果中。
代码如下：
public static void main(String[] args) {
//Calculating square root of even numbers from 1 to N
int min = 1;
int max = 1000000;
List<Integer> sourceList = new ArrayList<>();
for (int i = min; i < max; i++) {
sourceList.add(i);
}
List<Double> result = new LinkedList<>();
//Collections approach
long t0 = System.nanoTime();
long elapsed = 0;
for (Integer i : sourceList) {
if(i % 2 == 0){
result.add(Math.sqrt(i));
}
}
elapsed = System.nanoTime() - t0;
System.out.printf("Collections: Elapsed time:\t %d ns \t(%f seconds)%n", elapsed, elapsed / Math.pow(10, 9));
//Stream approach
Stream<Integer> stream = sourceList.stream();
t0 = System.nanoTime();
result = stream.filter(i -> i%2 == 0).map(i -> Math.sqrt(i)).collect(Collectors.toList());
elapsed = System.nanoTime() - t0;
System.out.printf("Streams: Elapsed time:\t\t %d ns \t(%f seconds)%n", elapsed, elapsed / Math.pow(10, 9));
//Parallel stream approach
stream = sourceList.stream().parallel();
t0 = System.nanoTime();
result = stream.filter(i -> i%2 == 0).map(i -> Math.sqrt(i)).collect(Collectors.toList());
elapsed = System.nanoTime() - t0;
System.out.printf("Parallel streams: Elapsed time:\t %d ns \t(%f seconds)%n", elapsed, elapsed / Math.pow(10, 9));
}.
以下是双核机器的结果：
Collections: Elapsed time: 94338247 ns (0,094338 seconds)
Streams: Elapsed time: 201112924 ns (0,201113 seconds)
Parallel streams: Elapsed time: 357243629 ns (0,357244 seconds)
对于这个特定的测试，流的速度大约是集合的两倍，并且并行性没有帮助（或者我使用它的方式错误？）。
问题：
- 这个测试公平吗？我犯了什么错误吗？
- 流比集合慢吗？有没有人为此制定了良好的正式基准？
- 我应该争取哪种方法？
更新结果。
按照@pveentjer 的建议，我在 JVM 预热（1k 次迭代）后运行了 1k 次测试：
Collections: Average time: 206884437,000000 ns (0,206884 seconds)
Streams: Average time: 98366725,000000 ns (0,098367 seconds)
Parallel streams: Average time: 167703705,000000 ns (0,167704 seconds)
在这种情况下，流的性能更高。我想知道在运行时仅调用一次或两次过滤功能的应用程序中会观察到什么。
【问题讨论】：
-
你试过用
IntStream代替吗？ -
你能正确测量吗？如果您所做的只是一次运行，那么您的基准测试当然会关闭。
-
@MisterSmith 我们能否对您如何预热 JVM 以及 1K 测试提供一些透明度？
-
对于那些有兴趣编写正确的微基准测试的人，问题是：stackoverflow.com/questions/504103/…
-
@assylias 使用
toList应该并行运行，即使它正在收集到非线程安全列表，因为不同的线程在合并之前会收集到线程受限的中间列表。
标签： java performance collections java-8 java-stream