Java8新特性系列（流性能）
题图：by pixel2013 From pixabay
上期介绍了Java8中
Stream的新特性，本期我们将测试下stream与parallelStream的性能以及应用的场景。
先上代码
public class StreamTest {
private static final int MAX_INT = 1_000_000;
public static void stream() {
List<String> list = new ArrayList<>();
IntStream.range(0, MAX_INT).forEach(value -> {
UUID uuid = UUID.randomUUID();
list.add(uuid.toString());
});
long startTime = System.nanoTime();
list.stream().sorted().collect(Collectors.toList());
long endTime = System.nanoTime();
long durationTime = TimeUnit.NANOSECONDS.toMillis(endTime - startTime);
System.out.println("stream execute time : " + durationTime);
}
public static void parallelStream() {
List<String> list = new ArrayList<>();
IntStream.range(0, MAX_INT).forEach(value -> {
UUID uuid = UUID.randomUUID();
list.add(uuid.toString());
});
long startTime = System.nanoTime();
list.parallelStream().sorted().collect(Collectors.toList());
long endTime = System.nanoTime();
long durationTime = TimeUnit.NANOSECONDS.toMillis(endTime - startTime);
System.out.println("parallelStream execute time : " + durationTime);
}
public static void main(String[] args) {
stream();
parallelStream();
}
}
MAX_INT = 1_000_000; //Jav8中数字可以用_间隔，类似1,000,000
Max_INT为1时，结果为：
stream execute time : 6
parallelStream execute time : 8
Max_INT为100时，结果为：
stream execute time : 7
parallelStream execute time : 7
Max_INT为1_000时，结果为：
stream execute time : 15
parallelStream execute time : 22
Max_INT为10_000时，结果为：
stream execute time : 28
parallelStream execute time : 21
Max_INT为100_000时，结果为：
stream execute time : 98
parallelStream execute time : 62
Max_INT为1_000_000时，结果为：
stream execute time : 742
parallelStream execute time : 429
Max_INT为5_000_000时，结果为：
stream execute time : 4299
parallelStream execute time : 2191
Max_INT为10_000_000时，结果为：
stream execute time : 9849
parallelStream execute time : 6923
分析
并行适用的场景？
- 有大量的元素要处理
- 性能问题是首要考虑的
- 没有在一个多线程的环境中
所以如Java Web应用，底层都是Servlet，我们知道，Servlet是多线程的，所以在web应用中并行流并不适用，而对于数据的处理、算法的验证等单线程环境是适用的。
原理
并行流底层其实是ForkJoinPool ，用的是分治法，即Fork/Join方法
当执行新的任务时它可以将其拆分分成更小的任务执行，并将小任务加到线 程队列中，然后再从一个随机线程的队列中偷一个并把它放在自己的队列中。
相对于一般的线程池实现，fork/join框架的优势体现在对其中包含的任务的处理方式上，在一般的线程池中，如果一个线程正在执行的任务由于某些原因无法继续运行,那么该线程会处于等待状态。而在fork/join框架实现中，如果某个子问题由于等待另外一个子问题的完成而无法继续运行.那么处理该子问题的线程会主动寻找其他尚未运行的子问题来执行。这种方式减少了线程的等待时间，提高了性能。
public static void main(String[] args) {
ForkJoinPool pool = ForkJoinPool.commonPool();
System.out.println(pool.getParallelism());
}
结果：
3
我们可以通过参数来修改：
WX20171230-125634@2x.png
结果：
10
总结
如何高效使用并行流？
- 如果用循环还是顺序流或者是并行流，像我们上面那样测试一下；
- 注意装箱，尽量使用
IntStream,LongStream，和DoubleStream来避免装箱拆箱; - 有些操作在并行流上性能很差，比如
limit，findFirst等依赖顺序的操作。unordered方法可以把有序流转为无序流，使用findAny等好很多，在无序流上用limit也好很多; - 计算流水线操作总成本，处理单个元素用时越多，并行就越划算；
- 对于较小的数据量，用并行不一定是好事儿；
- 区分单线程和多线程，多线程下并行不一定是好事儿；
- 数据结果是否易于分解，比如
ArrayList比LinkedList易于分解，range创建的原始流也易于分解； - 终端操作中的合并大家是否很大，大了也不划算。
