java8之stream流的基本操做

1、stream流簡介

Stream流是數據渠道，用於操做數據源（集合、數組等）所生成的元素序列。
Stream的優勢：聲明性，可複合，可並行。這三個特性使得stream操做更簡潔，更靈活，更高效。
Stream的操做有兩個特色：能夠多個操做連接起來運行，內部迭代。
Stream可分爲並行流與串行流，Stream API 能夠聲明性地經過 parallel() 與sequential() 在並行流與順序流之間進行切換。
串行流就沒必要再細說了，並行流主要是爲了爲了適應目前多核機器的時代，提升系統CPU、內存的利用率，並行流就是把一個內容分紅多個數據塊，並用不一樣的線程分別處理每一個數據塊的流。java1.8並行流使用的是fork/join框架，關於fork/join框架可參考http://ifeve.com/talk-concurrency-forkjoin/學習。

注意點：
一、Stream不會本身存儲數據。
二、Stream不會改變原對象，他們會返回一個新的Stream。
三、Stream操做是延遲的，他們會等到須要的結果時才執行。
四、使用並行流並不必定會提升效率，由於jvm對數據進行切片和切換線程也是須要時間的。

2、建立stream流的方式

//一、經過Collection系列提供的stream()（串行） 或parallelStream()（並行）獲取
List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();//串行流
Stream<String> stream2 = list.parallelStream();//並行流
 //二、經過Arrays中的靜態方法stream() 獲取數據流
User[] u = new User[2];
Stream<User> stream3 = Arrays.stream(u);
 //三、經過Stream；類中的靜態方法of()
Stream<String> stream4 = Stream.of("11","2");

3、篩選和切片

一、filter(predicate)-接收lambda，從流中排除某些元素。
二、limit(n)-截斷流，使其元素不超過給定數量。
三、skip(n)-跳過元素，返回一個扔掉了前n個元素的流。若流中元素不足n個，則返回一個空流，與limit(n)互補。
四、distinct-篩選，經過流所生成元素的hashcode()和equals()去重複元素。

/**
   * 打印年齡大於18的前4位用戶信息（不重複）
   * 並跳過第1個用戶
   */
@Test
  public void test1(){
    list.stream()
    .filter((x)->x.getAge()>18)
    .distinct()
    .limit(4)
    .skip(1).forEach(System.out::println);
  }

4、映射

一、map，接收Lambda，將元素轉換成其餘形式或提取信息。接收一個函數做爲參數，該函數會被應用到每個元素上，並將其映射成一個新的元素。
二、mapToDouble/mapToInt/mapToLong，接收一個函數做爲參數，該函數會被應用到每一個元素上，產生一個新DoubleStream/IntStream/LongStream。
3 、flatMap，接收一個函數做爲參數，將流中的每一個值都換成一個流，而後把流鏈接成一個流。

@Test
 public void test2(){
   ///map
   list.stream().map(User::getName)
   .forEach(System.out::println);
   //flatMap
   List<List<User>> list1 = new ArrayList<>();
   list1.add(list);
   list1.stream().flatMap(Stream::getNames)
   .forEach(System.out::println);
 }
 public static Stream<String> getNames(List<User> list){
   List<String> list1 = new ArrayList<String>();
   for (User user : list) {
     list1.add(user.getName());
   }
   return list1.stream();
 }

5、排序

一、sorted()，產生一個新流，其中按天然順序排序。 
二、sorted(Comparator)，產生一個新流，其中按比較器順序排序。

@Test
  public void test3(){
    List<String> list =Arrays.asList("aa","bb","cc","dd");
    list.stream().sorted()
    .forEach(System.out::println);
    //
    list.stream().sorted((x,y) -> {
      if(x.equals(y)){
        return 1;
      }else{
        return -1;
      }
    } ).forEach(System.out::println);
  }

6、查找與匹配

一、allMatch,檢查是否匹配全部元素。 
二、anyMatch,檢查是否至少匹配一個元素。 
三、noneMatch,檢查是否沒有匹配全部元素。 
四、findFirst,返回第一個元素。 
五、findAny,返回當前流中的任意元素。 
六、count,返回流中元素的總數。 
七、 max,返回流中最大值。 
八、min,返回流中最小值。 
九、froEach(Consumer c) 內部迭代。

@Test
  public void test4(){
    boolean b = list.stream().
        noneMatch((e) ->
        e.getName().equals("zhao"));
    System.out.println(b);
    Optional<User> op = list.parallelStream()
        .filter((x) -> x.getAge() == 18)
        .findAny();
    System.out.println(op.get());
  }

7、彙總測試

@Test
  public void test5(){
    //轉List
    List<String> list1 =list.stream()
        .map(User::getName)
        .collect(Collectors.toList()) ;
    list1.forEach(System.out::println);
    //轉HashSet
    HashSet<String> set = list.stream().
        map(User::getName)
        .collect(Collectors.toCollection(HashSet::new));
    set.forEach(System.out::println);
    //總數
    Long count = list.stream()
        .collect(Collectors.counting());
    System.out.println(count);
    //平均年齡
    double avAge = list.stream()
        .collect(Collectors.averagingInt(User::getAge));
    System.out.println(avAge); 
    //總年齡
    int toAge = list.stream()
        .collect(Collectors.summingInt(User::getAge));
    System.out.println(toAge);
    //最大值
    Optional<User> u = list.stream()
        .collect(Collectors.maxBy((e1,e2) 
            -> Integer.compare(e1.getAge(),e2.getAge() )));
    System.out.println(u);
    //平均年齡
    IntSummaryStatistics collect = list.stream()
        .collect(Collectors.summarizingInt(User::getAge));
    System.out.println(collect.getAverage());
    //分組
    Map<Integer, List<User>> l= list.stream()
        .collect(Collectors.groupingBy(User::getAge));
    System.out.println(l);
    //多級分組
    Map<Integer,Map<String,List<User>> > ls= list.stream()
        .collect(Collectors.groupingBy(
            User::getAge,Collectors.groupingBy(User::getSex)));
    System.out.println(ls);
    //分區
    Map<Boolean,List<User>> map= list.stream()
        .collect(Collectors.partitioningBy((x) 
            -> x.getAge()>18));
    System.out.println(map);
    //鏈接字符串
    String str = list.stream().map(User::getName)
        .collect(Collectors.joining(",","-","-"));
    System.out.println(str);
  }