【java8新特性 简述】Stream API

java8的又一特性就是 流（Stream），流主要是对数据源（集合、数组等）的一种处理方式，有高效的聚合操作、大批量的数据处理，同时也内置了许多运算方式，包括筛选、排序、聚合等 ，特别提醒：流运用了大量的lambda表达式。 这里只是列出一些常用的知识点，帮助你快速了解它。

几大特点

1. 与lambda表达式结合，代码极简，可读性高
2. 提供并行操作，充分发挥多核处理器优势
3. 进行并行操作，无需额外编写多线程代码即可实现高效并发程序，规避多线程代码问题

简单基本概念

• 元素 流Stream是来自数据源的元素队列，本身不具备元素
• 数据源 包括包含集合、数组、I/O channel、generator（发生器）等
• 聚合操作 类似SQL中的filter、map、find、match、sorted等操作
• 管道运算 Stream在Pipeline中运算后返回Stream对象本身，这样多个操作串联成一个Pipeline，并形成fluent风格的代码。这种方式可以优化操作，如延迟执行(laziness)和短路( short-circuiting)。(我理解为链式操作)
• 内部迭代 不同于java8以前对集合的遍历方式（外部迭代），采用访问者模式（Visitor）实现了内部迭代。
• 并行运算 Stream API支持串行（stream() ）或并行（parallelStream() ）的两种操作方式。

简单实例

• java8之前

public static void main(String[] args)
    {  
        List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);
        
        long count = 0;
        
        for(Integer number: numbers)
        {
            if(number > 0)
            {
                count++;
            }
        }
        
        System.out.println("Positive count: " + count);
    }

通常利用for循环遍历

• java8之后

public static void main(String[] args)
    {  
        List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);
      
        long count = numbers.parallelStream().filter(i -> i>0).count();
        
        System.out.println("Positive count: " + count);
    }

上例中，使用filter()方法对数组进行了过滤，使用count()方法对过滤后的数组进行了大小统计，且使parallelStream()方法为集合创建了并行流，自动采用并行运算提高速度。在更复杂的场景，还可以用forEach()、map()、limit()、sorted()、collect()等方法进行进一步的流运算。
并且 通常会和lambda表达式一起使用，使得代码更加优雅。

常用接口

• Stream的生成（ 串行流 ： stream()； 并行流 ： parallelStream()）

List list = new ArrayList();
list.stream().//接下来管道操作

• forEach()方法 (用来迭代流中的每一个数据)

List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);
numbers.stream().forEach(n ->  System.out.println("List element: " + n));

• map()方法 (将流中的所有元素用Function对象进行运算，生成新的流对象)

List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);        
 numbers.stream().map( n -> Math.abs(n)).forEach(n ->  System.out.println("Element abs: " + n));

• flatMap()方法 (比map()方法拥有更高的映射深度)

用flatMap()方法如下：

List<String> list = Arrays.asList("1 2", "3 4", "5 6");
list.stream().flatMap(item -> Arrays.stream(item.split(" "))).forEach(System.out::println);

而用map()方法：

List<String> list = Arrays.asList("1 2", "3 4", "5 6");
list.stream().map(item -> Arrays.stream(item.split(" "))).forEach(n ->n.forEach(System.out::println));

可见，用map()方法，返回了一个“流中流”，需要在每个Stream元素遍历时，再加一层forEach进行遍历。

• filter()方法 (过滤)

List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);      
long count = numbers.parallelStream().filter(i -> i>0).count();        
System.out.println("Positive count: " + count);

• reduce()方法 (为折叠操作，用于将流中的所有值合成一个)

List<Integer> numbers = Arrays.asList(-1, -2, 0, -1, 4, 5, 1);        
 Integer total = numbers.stream().reduce((t, n) -> t + n).get();        
System.out.println("Total: " + total);

• collect()方法 (将流转为数据源 （集合等）)
  collect()方法的参数为一个java.util.stream.Collector类型对象，可以用java.util.stream.Collectors工具类提供的静态方法来生成，Collectors类实现很多的归约操作，如Collectors.toList()、Collectors.toSet()、Collectors.joining()（joining适用于字符串流）等

List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);        
List<Integer> abss = numbers.stream().map( n -> Math.abs(n)).collect(Collectors.toList());
 System.out.println("Abs list: " + abss);

• 数值操作的方法
  Stream采用mapToInt()、mapToLong()、mapToDouble()三个方法分别生成IntStream 、LongStream 、DoubleStream 三个接口类型的对象
  IntStream 、LongStream 、DoubleStream 三个接口类型都有一个summaryStatistics()方法，其中，
  IntStream 的方法是：IntSummaryStatistics summaryStatistics();
  LongStream 的方法是：LongSummaryStatistics summaryStatistics();
  DoubleStream 的方法是：DoubleSummaryStatistics summaryStatistics();
  在IntSummaryStatistics、LongSummaryStatistics 、DoubleSummaryStatistics三个接口类型（位于java.util包下）中，都有诸如统计数量、最大值、最小值、求和、平均值等方法（方法名和返回类型可能不同）,可以方便的进行数值统计。

看这么多文字，还是来个例子消化比较好：

List<Integer> numbers = Arrays.asList(-1, -2, 0, 4, 5);        
IntSummaryStatistics stats = numbers.stream().mapToInt((x) -> x).summaryStatistics();        
System.out.println("Max : " + stats.getMax());
System.out.println("Min : " + stats.getMin());
System.out.println("Sum : " + stats.getSum());
System.out.println("Average : " + stats.getAverage());
System.out.println("Count : " + stats.getCount());

• 其它方法
  Stream API还有一些其它的方法，比如：
  　　　　limit()　　　 获取指定数量的流
  　　　　sorted()　 　对流进行排序
  　　　　distinct()　　去重
  　　　　skip()　　　　跳过指定数量的元素
  　　　　peek()　　　生成一个包含原Stream的所有元素的新Stream，并指定消费函数
  　　　　count()　　　计算元素数量

这部分只是流stream的冰山一角，想要深入的朋友可以去看下java8的关于流这部分的源码，进行深入学习。