posts - 325,  comments - 25,  trackbacks - 0
          *
           * 一、Stream API 的操作步驟:
           *
           * 1. 創(chuàng)建 Stream
           *
           * 2. 中間操作
           *
           * 3. 終止操作(終端操作)
           */
          public class TestStreamaAPI {
           
           //1. 創(chuàng)建 Stream
           @Test
           public void test1(){
            //1. Collection 提供了兩個方法  stream() 與 parallelStream()
            List<String> list = new ArrayList<>();
            Stream<String> stream = list.stream(); //獲取一個順序流
            Stream<String> parallelStream = list.parallelStream(); //獲取一個并行流
            
            //2. 通過 Arrays 中的 stream() 獲取一個數(shù)組流
            Integer[] nums = new Integer[10];
            Stream<Integer> stream1 = Arrays.stream(nums);
            
            //3. 通過 Stream 類中靜態(tài)方法 of()
            Stream<Integer> stream2 = Stream.of(1,2,3,4,5,6);
            
            //4. 創(chuàng)建無限流
            //迭代
            Stream<Integer> stream3 = Stream.iterate(0, (x) -> x + 2).limit(10);
            stream3.forEach(System.out::println);
            
            //生成
            Stream<Double> stream4 = Stream.generate(Math::random).limit(2);
            stream4.forEach(System.out::println);
            
           }
           
           //2. 中間操作
           List<Employee> emps = Arrays.asList(
             new Employee(102, "李四", 59, 6666.66),
             new Employee(101, "張三", 18, 9999.99),
             new Employee(103, "王五", 28, 3333.33),
             new Employee(104, "趙六", 8, 7777.77),
             new Employee(104, "趙六", 8, 7777.77),
             new Employee(104, "趙六", 8, 7777.77),
             new Employee(105, "田七", 38, 5555.55)
           );
           
           /*
             篩選與切片
            filter——接收 Lambda , 從流中排除某些元素。
            limit——截斷流,使其元素不超過給定數(shù)量。
            skip(n) —— 跳過元素,返回一個扔掉了前 n 個元素的流。若流中元素不足 n 個,則返回一個空流。與 limit(n) 互補
            distinct——篩選,通過流所生成元素的 hashCode() 和 equals() 去除重復(fù)元素
            */
           
           //內(nèi)部迭代:迭代操作 Stream API 內(nèi)部完成
           @Test
           public void test2(){
            //所有的中間操作不會做任何的處理
            Stream<Employee> stream = emps.stream()
             .filter((e) -> {
              System.out.println("測試中間操作");
              return e.getAge() <= 35;
             });
            
            //只有當(dāng)做終止操作時,所有的中間操作會一次性的全部執(zhí)行,稱為“惰性求值”
            stream.forEach(System.out::println);
           }
           
           //外部迭代
           @Test
           public void test3(){
            Iterator<Employee> it = emps.iterator();
            
            while(it.hasNext()){
             System.out.println(it.next());
            }
           }
           
           @Test
           public void test4(){
            emps.stream()
             .filter((e) -> {
              System.out.println("短路!"); // &&  ||
              return e.getSalary() >= 5000;
             }).limit(3)
             .forEach(System.out::println);
           }
           
           @Test
           public void test5(){
            emps.parallelStream()
             .filter((e) -> e.getSalary() >= 5000)
             .skip(2)
             .forEach(System.out::println);
           }
           
           @Test
           public void test6(){
            emps.stream()
             .distinct()
             .forEach(System.out::println);
           }
          posted on 2018-03-06 08:36 長春語林科技 閱讀(134) 評論(0)  編輯  收藏 所屬分類: java8
          <2018年3月>
          25262728123
          45678910
          11121314151617
          18192021222324
          25262728293031
          1234567

           

          長春語林科技?xì)g迎您!

          常用鏈接

          留言簿(6)

          隨筆分類

          隨筆檔案

          文章分類

          文章檔案

          相冊

          收藏夾

          搜索

          •  

          最新評論

          閱讀排行榜

          評論排行榜

          主站蜘蛛池模板: 凤冈县| 沁水县| 定安县| 德保县| 封丘县| 商都县| 兴业县| 桐城市| 阳江市| 吉木萨尔县| 咸宁市| 芦溪县| 平原县| 桐城市| 东阿县| 淮北市| 三门县| 友谊县| 兴和县| 彰化市| 察隅县| 建始县| 绥芬河市| 牡丹江市| 南投市| 崇州市| 闵行区| 石渠县| 东乡县| 兴海县| 宜城市| 东乌| 嘉定区| 昌吉市| 梁山县| 榆中县| 滦平县| 郑州市| 凤凰县| 彭州市| 翁源县|