Java8简明学习之Lambda表达式

2018-07-25 13:06:03来源：博客园阅读 ()

函数式接口

　　就是一个有且仅有一个抽象方法，但是可以有多个非抽象方法的接口，函数式接口可以被隐式转换为lambda表达式。

　　之前已有的函数式接口:
　　java.lang.Runnable
　　java.util.concurrent.Callable
　　java.util.Comparator
　　java.io.FileFilter

　　1.8新增的函数式接口：
　　java.util.function包下

　　Predicate<T>——接收 T 并返回 boolean （常用）
　　Consumer<T>——接收 T，不返回值（常用）
　　Function<T, R>——接收 T，返回 R （常用）
　　Supplier<T>——提供 T 对象（例如工厂），不接收值
　　UnaryOperator<T>——接收 T 对象，返回 T
　　BinaryOperator<T>——接收两个 T，返回 T

lambda表达式

　　lambda表达式的语法由参数列表、箭头符号 -> 和函数体组成。函数体既可以是一个表达式，也可以是一个语句块。
　　eg: (int x, int y) -> x + y （表达式）
　　eg：(Integer e) -> {
　　　　double sqrt = Math.sqrt(e);
　　　　double log = Math.log(e);

　　　　return sqrt + log;
　　} （语句块）
　　意义：传入参数x和y，返回x和y的和
　　表达式：表达式会被执行然后返回执行结果。
　　语句块：语句块中的语句会被依次执行，就像方法中的语句一样。

方法引用:

　　方法引用提供了非常有用的语法，可以直接引用已有Java类或对象（实例）的方法或构造器。
　　方法引用有很多种，它们的语法如下：
　　静态方法引用：ClassName::methodName
　　实例上的实例方法引用：instanceReference::methodName
　　超类上的实例方法引用：super::methodName
　　类型上的实例方法引用：ClassName::methodName
　　构造方法引用：Class::new
　　数组构造方法引用：TypeName[]::new

　　eg:

List<String> names5 = Arrays.asList("peter", "anna", "mike", "xenia");
        names5.sort(String::compareTo);
        System.out.println(names5);

public void testFun1() {
// comparing 是 Function<? super T, ? extends U> Function<T, R>——接收 T，返回 R
Person p1 = new Person();
p1.setName("hy");
p1.setAge(18);

Person p2 = new Person();
p2.setName("dax");
p2.setAge(19);

Person[] people = {p1, p2};
Comparator<Person> byName = Comparator.comparing(Person::getName);
Arrays.sort(people, byName);
for (Person person : people) {
System.out.println(person);
}
}

Stream

Stream与 java.io 包里的 InputStream 和 OutputStream 是完全不同的概念，Stream 是对集合（Collection）对象功能的增强。

eg：内部迭代和外部迭代

 void innerOrOuter() {
        List<Person> list = new ArrayList<>();
        Person p1 = new Person();
        p1.setName("hy");
        p1.setAge(18);

        Person p2 = new Person();
        p2.setName("dax");
        p2.setAge(19);

        list.add(p1);
        list.add(p2);

        for (Person p: list) {
            p.setAge(20);
        }
        System.out.println(list);

        List<Person> list2 = new ArrayList<>();
        Person p21 = new Person();
        p21.setName("hy");
        p21.setAge(18);

        Person p22 = new Person();
        p22.setName("dax");
        p22.setAge(19);

        list2.add(p21);
        list2.add(p22);

        list2.stream().forEach(p->p.setAge(20));
        System.out.println(list2);
    }

　　Stream通用语法：

　　Stream的操作：
　　Intermediate（中间操作）：
　　　　map (mapToInt, flatMap 等)、 filter、 distinct（去重）、 sorted（排序）、 peek（对某个元素做单独处理生成新的Stream）、
　　　　limit（取前N个元素）、 skip（丢弃前N个元素）、 parallel、 sequential、 unordered

　　Terminal（结束操作，非短路操作）：
　　　　forEach、 forEachOrdered、 toArray、 reduce、 collect、 min、 max、 count、 anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 iterator

　　Short-circuiting（结束操作，短路操作）：
　　　　anyMatch、 allMatch、 noneMatch、 findFirst、 findAny、 limit

　　代表例子：

@Test
public void testNormal() {
    // 1 线程
    new Thread(()-> testThread()).start();

    // 2 遍历集合
    List<String> list = Arrays.asList("abd", "nba", "cba", "mctrady");
    list.stream().forEach(n-> System.out.println(n));
    list.forEach(n-> System.out.println(n));

    // 3 map运用
    List<Integer> listInt = Arrays.asList(123, 456, 789, 101);
    listInt.stream().map(n->n*10).forEach(n-> System.out.println(n));
    System.out.println(listInt.stream().mapToInt(n->n).sum());
    System.out.println(listInt.stream().mapToInt(n->n).average().getAsDouble());

    // 4 filter
    List<Integer> listInt2 = Arrays.asList(123, 456, 789, 101);
    listInt2.stream().filter(n->n>200).forEach(n-> System.out.println(n));


    // 5 对每个元素应用函数
    List<Integer> listInt3 = Arrays.asList(123, 456, 789, 101);
    String str = listInt3.stream().map(n->n.toString()).collect(Collectors.joining(","));
    System.out.println(str);
}

private void testThread() {
    System.out.println("线程操作");
}

List<String> names = Arrays.asList("peter", "anna", "mike", "xenia");
        Collections.sort(names, new Comparator<String>() {
            @Override
            public int compare(String a, String b) {
                return b.compareTo(a);
            }
        });
        System.out.println(names);

        List<String> names1 = Arrays.asList("peter", "anna", "mike", "xenia");
        Collections.sort(names1, (String a, String b) -> {
            return b.compareTo(a);
        });
        System.out.println(names1);

        List<String> names2 = Arrays.asList("peter", "anna", "mike", "xenia");
        Collections.sort(names2, (String a, String b) -> b.compareTo(a));
        System.out.println(names2);

        List<String> names3 = Arrays.asList("peter", "anna", "mike", "xenia");
        Collections.sort(names3, (a, b) -> b.compareTo(a));
        System.out.println(names3);

        List<String> names4 = Arrays.asList("peter", "anna", "mike", "xenia");
        Collections.sort(names4, String::compareTo);
        System.out.println(names4);

        List<String> names5 = Arrays.asList("peter", "anna", "mike", "xenia");
        names5.sort(String::compareTo);
        System.out.println(names5);

        List<String> names6 = Arrays.asList("peter", "anna", "mike", "xenia");
        // 反转
        names6.sort(Comparator.comparing(String::toString).reversed());
        System.out.println(names6);

public void testStream() throws ClassNotFoundException {
        List<Person> list = new ArrayList<>();
        Person p1 = new Person();
        p1.setName("hy");
        p1.setAge(18);

        Person p2 = new Person();
        p2.setName("dax");
        p2.setAge(19);

        list.add(p1);
        list.add(p2);

        System.out.println(list);

        list.stream().forEach(p -> p.setAge(20));

        System.out.println(list);

        list.stream().filter(s->s.getName().equals("hy")).forEach(p->p.setAge(21));
        System.out.println(list);

        List<Person> listHy = list.stream().filter(s->s.getName().equals("hy") && s.getAge() == 21).collect(Collectors.toList());
        System.out.println(listHy);

        int age = list.stream().mapToInt(s->s.getAge()).sum();
        System.out.println("年龄总和：" + age);

        Optional<Person> firstHy = list.stream()
                .filter(s -> s.getName().equals("hy"))
                .findFirst();
        Person person = firstHy.get();
        System.out.println(person);
    }