JAVA8 lambda表达式权威教程

【1】Collection接口中的方法：
        default Stream<E> stream()  获取串行流
        default Stream<E> parallelStream() 获取并行流
      案例：

//方式1：Collection接口的方法
Collection collection = new ArrayList();
Stream stream = collection.stream();
Stream stream1 = collection.parallelStream();

//方式2：通过Arrays中的Stream方法  数组
IntStream stream2 = Arrays.stream(new int[]{1, 2, 3, 4, 5});

//方式3：Stream中的of方法
Stream<String> stream3 = Stream.of("111", "222", "333");

//方法4：Stream中的方法  创建无限流  （结果是无线个）
Stream<Integer> iterate = Stream.iterate(2, (x) -> x + 2);

 //1：创建Stream;
  Stream<Student> stream = list.stream();

 //2：filter方法（找到年龄大于等于18岁的学生）
 Stream<Student> studentStream = stream.filter((student) -> student.getAge() >= 18);

  //3：终止操作;如果没有终止操作的话，上面的第二步中间操作不执行
   studentStream.forEach(System.out::println);
   /**
    * 注意：如果值执行1,2操作的话，不会有任何结果。
    * 验证出Steam操作是延迟的，只有进行了终止操作，才会执行中间操作！这就是所谓的延迟加载
*/

 public void limitTest02() {
        //Limit方法 短路(效率增高)，只要找到了2个满足条件的，后面的迭代操作就不在执行了！
        list.stream().filter(x -> {
            System.out.println("正在过滤！！");
            return x.getAge() > 18;
        }).limit(2).forEach(System.out::println);
    }

public void skipTest03() {
     //skip 方法跳过前2个满足条件的  留下后面满足条件的结果！！
     list.stream().filter(x -> {
         System.out.println("正在过滤后面满足条件的结果");
         return x.getAge() > 18;
     }).skip(2).forEach(System.out::println);
 }

 public void distinctTest04() {
   //distinct 去重操作！
       list.stream().distinct().forEach(System.out::println);
   }

@Test
public void testMap() {
    Stream<String> original = Stream.of("11", "22", "33");
    Stream<Integer> result = original.map(Integer::parseInt);
    result.forEach(s -> System.out.println(s + 10));
}
//这段代码中，map方法的参数通过方法引用，将字符串类型转换成为了int类型（并自动装箱为Integer类对象）。

基本使用
Stream流中的sorted方法基本使用的代码如：
@Test
public void testSorted() {
    // sorted(): 根据元素的自然顺序排序
    // sorted(Comparator<? super T> comparator): 根据比较器指定的规则排序
    Stream.of(33, 22, 11, 55)
            .sorted()
            .sorted((o1, o2) -> o2 - o1)
            .forEach(System.out::println);
}
这段代码中，sorted方法根据元素的自然顺序排序，也可以指定比较器排序。

@Test
public void testFind() {
    Optional<Integer> first = Stream.of(5, 3, 6, 1).findFirst();
    System.out.println("first = " + first.get());

    Optional<Integer> any = Stream.of(5, 3, 6, 1).findAny();
    System.out.println("any = " + any.get());
}

@Test
public void testMatch() {
    boolean b = Stream.of(5, 3, 6, 1)
            // .allMatch(e -> e > 0); // allMatch: 元素是否全部满足条件
            // .anyMatch(e -> e > 5); // anyMatch: 元素是否任意有一个满足条件
            .noneMatch(e -> e < 0); // noneMatch: 元素是否全部不满足条件
    System.out.println("b = " + b);
}    

//forEach 用来遍历流中的数据
 @Test
    public void test02() {
        //案例1、2下面两种写法等同
        list.stream().map((x)->x.getName()).forEach(System.out::println);
        list.stream().map(Student::getName).forEach(System.out::println);
    }

List<String> list13 = Arrays.asList("zhangsan","lisi","wangwu","xuwujing");
 int maxLines = list13.stream().mapToInt(String::length).max().getAsInt();
 int minLines = list13.stream().mapToInt(String::length).min().getAsInt();
 System.out.println("最长字符的长度:" + maxLines+",最短字符的长度:"+minLines);
 //最长字符的长度:8,最短字符的长度:4

 // Stream流提供count方法来统计其中的元素个数：long count();
  //该方法返回一个long值代表元素个数。基本使用：
@Test
public void testCount() {
   List<String> strList = new ArrayList<>();
   Collections.addAll(strList, "张无忌", "周芷若", "赵敏", "小昭", "杨不悔);
   System.out.println(strList.stream().count());
}

// 案例：
    @Test
    public void testGroup() {
        Stream<Student> studentStream = Stream.of(
                new Student("赵丽颖", 52, 95),
                new Student("杨颖", 56, 88),
                new Student("迪丽热巴", 56, 55),
                new Student("柳岩", 52, 33));
        // Map<Integer, List<Student>> map = studentStream.collect(Collectors.groupingBy(Student::getAge));
        // 将分数大于60的分为一组,小于60分成另一组
        Map<String, List<Student>> map = studentStream.collect(Collectors.groupingBy((s) -> {
            if (s.getSocre() > 60) {
                return "及格";
            } else {
                return "不及格";
            }
        }));
        map.forEach((k, v) -> {
            System.out.println(k + "::" + v);
        });
    }

效果：
不及格::[Student{name='迪丽热巴', age=56, socre=55}, Student{name='柳岩', age=52, socre=33}]
及格::[Student{name='赵丽颖', age=52, socre=95}, Student{name='杨颖', age=56, socre=88}]

Collectors.joining会根据指定的连接符，将所有元素连接成一个字符串。
// 拼接
@Test
public void testJoining() {
    Stream<Student> studentStream = Stream.of(
            new Student("赵丽颖", 52, 95),
            new Student("杨颖", 56, 88),
            new Student("迪丽热巴", 56, 99),
            new Student("柳岩", 52, 77));
    String collect = studentStream
            .map(Student::getName)
            .collect(Collectors.joining(">_<", "^_^", "^v^"));
    System.out.println(collect);
}

// 将流中数据收集到集合中
@Test
public void testStreamToCollection() {
    Stream<String> stream = Stream.of("aa", "bb", "cc");
    // List<String> strList = stream.collect(Collectors.toList());
    // Set<String>  strSet = stream.collect(Collectors.toSet());

    ArrayList<String> arrayList = stream.collect(Collectors.toCollection(ArrayList::new));
    HashSet<String> hashSet = stream.collect(Collectors.toCollection(HashSet::new));
}

@Test
    public void testCollectToMap(){
        //案例1
        List<Integer> list = Arrays.asList(1, 2, 3);
        Map<String, String> collect1 = list.stream().map(i -> i).collect(Collectors.toMap(key -> "key" + key, value -> "value:" + value));
 
        //实体list转化map id作为主键，对象作为value
        List<User> userList =new ArrayList<User>();
        UserTask userTask = new UserTask();
        userTask.setId(1);
        userTask.setName("测试");
        userList.add(userTask);
 
        Map<Integer,UserTask> taskMap = userList.stream().collect(Collectors.toMap(UserTask::getId, entity -> entity));
        System.out.println(collect1.toString());
        System.out.println(taskMap.toString());
    }