下面的例子就演示了如何使用并行流进行操作来提高运行效率,代码非常简单。
首先我们创建一个大的list,里面的元素都是唯一的:
- int max = 1000000;
- List<String> values = new ArrayList<>(max);
- for (int i = 0; i < max; i++) {
- UUID uuid = UUID.randomUUID();
- values.add(uuid.toString());
- }
现在,我们测量一下对这个集合进行排序所使用的时间。
顺序排序
- long t0 = System.nanoTime();
- long count = values.stream().sorted().count();
- System.out.println(count);
- long t1 = System.nanoTime();
- long millis = TimeUnit.NANOSECONDS.toMillis(t1 - t0);
- System.out.println(String.format("sequential sort took: %d ms", millis));
- // sequential sort took: 899 ms
并行排序
- long t0 = System.nanoTime();
- long count = values.parallelStream().sorted().count();
- System.out.println(count);
- long t1 = System.nanoTime();
- long millis = TimeUnit.NANOSECONDS.toMillis(t1 - t0);
- System.out.println(String.format("parallel sort took: %d ms", millis));
- // parallel sort took: 472 ms
如你所见,所有的代码段几乎都相同,唯一的不同就是把stream()改成了parallelStream(), 结果并行排序快了50%。