Java8 流式Lambda相关案例

package com.swj.base.stream; import com.swj.base.stream.model.Author; import com.swj.base.stream.model.Book; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.function.BinaryOperator; import java.util.function.Function; import java.util.stream.Collectors; import java.util.stream.Stream; public class StreamTest { public static void main(String[] args) { List<Author> authors = getAuthors(); /*authors.stream() .distinct() //.sorted() .sorted((o1, o2) -> o1.getAge() - o2.getAge()) .filter(x -> x.getAge() < 20) .forEach(author -> System.out.println(author.getName()));*/ // flatMap 演示实例1：打印所有书籍的名字，要求对重复单的元素去重 //map只能把一个对象转成另一个对象来作为流中的元素，而flatMap可以把一个对象转换成多个对象作为流中的元素 authors.stream() .flatMap(author -> author.getBooks().stream()) .distinct() .forEach(book -> System.out.println(book.getBookName())); // 打印现有数据的所有分类，要求对分类进行去重，不能出现这样的格式：哲学,爱情、 authors.stream() .flatMap(author -> author.getBooks().stream()) .distinct() .flatMap(book -> Stream.of(book.getCatetgory().split(","))) .distinct() .forEach(System.out::println); // 获取一个Map集合，map的key为作者名，value为List<Book> Map<String, List<Book>> map = authors .stream() .distinct() // 注意map的key是不能重复单，不然会报错 .collect(Collectors.toMap(new Function<Author, String>() { @Override public String apply(Author author) { return author.getName(); } }, new Function<Author, List<Book>>() { @Override public List<Book> apply(Author author) { return author.getBooks(); } })); System.out.println(map); //使用reduce求所有作者年龄的和 Integer sumAge = authors.stream() .distinct() .map(Author::getAge) .reduce(0, new BinaryOperator<Integer>() { @Override public Integer apply(Integer integer, Integer integer2) { return integer + integer2; } }); System.out.println(sumAge); //使用reduce求所有作者中年龄的最大值 Integer maxAge = authors.stream() .distinct() .map(Author::getAge) .reduce(Integer.MIN_VALUE, new BinaryOperator<Integer>() { // 初始化值可以设成一个最小的 @Override public Integer apply(Integer result, Integer integer2) { return result < integer2 ? integer2 : result; } }); //max&min封装好的方法，底层也是用的reduce System.out.println(maxAge); //使用reduce求所有作者中年龄的最小值 Integer minAge = authors.stream() .distinct() .map(Author::getAge) .reduce(Integer.MAX_VALUE, new BinaryOperator<Integer>() { // 初始化值可以设成一个最小的 @Override public Integer apply(Integer result, Integer integer2) { return result > integer2 ? integer2 : result; } }); System.out.println(minAge); } private static List<Author> getAuthors() { List<Author> list = new ArrayList<>(); List<Book> books = new ArrayList<>(); books.add(new Book("语文", "教科书,文科")); List<Book> books2 = new ArrayList<>(); books2.add(new Book("数学", "教科书,理科")); list.add(new Author(18, "张三", books)); list.add(new Author(18, "张三", books)); list.add(new Author(14, "李四", books)); list.add(new Author(25, "王五", books2)); return list; } }