💣 Java8新特性——四大内置函数式接口

---

Lambda 的设计者们为了让现有的功能与 Lambda 表达式良好兼容，考虑了很多方法，于是产生了函数接口这个概念。

什么是函数式接口？

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

但是在实践中，函数式接口非常脆弱，只要某个开发者在该接口中添加一个函数，则该接口就不再是函数式接口进而导致编译失败。为了克服这种代码层面的脆弱性，并显式说明某个接口是函数式接口，Java 8 提供了一个特殊的注解@FunctionalInterface，举个简单的函数式接口的定义：

@FunctionalInterface 
public interface GreetingService { 
    void sayMessage(String message); 
} 

Java7 只能通过匿名内部类进行编程，例如：

GreetingService greetService = new GreetingService() { 
 
    @Override 
    public void sayMessage(String message) { 
        System.out.println("Hello " + message); 
    } 
}; 
greetService.sayMessage("world"); 

Java8 可以采用 Lambda 表达方进行编程，例如：

GreetingService greetService = message -> System.out.println("Hello " + message); 
greetService.sayMessage("world"); 

目前 Java 库中的所有相关接口都已经带有这个注解了，实践上java.lang.Runnable和java.util.concurrent.Callable是函数式接口的最佳例子!

@FunctionalInterface注解

Java 8为函数式接口引入了一个新注解@FunctionalInterface，主要用于编译级错误检查，加上该注解，当你写的接口不符合函数式接口定义的时候，编译器会报错。

正确例子，没有报错：

/**
 * @Description FunctionalInterface
 * @Author vchicken
 * @Date 2022/9/24 14:46
 */
@FunctionalInterface
public interface TestFunctionalInterface {

    void sayMessage(String message);
    
}

错误例子，接口中包含了两个抽象方法，违反了函数式接口的定义，Eclipse报错提示其不是函数式接口。

提醒：加不加@FunctionalInterface对于接口是不是函数式接口没有影响，该注解知识提醒编译器去检查该接口是否仅包含一个抽象方法。

四大函数式接口

1.Function接口

什么是Function接口？

从Function接口的源代码，我们可以看出，JDK1.8之后才加入这个接口。Functional接口类中只有一个抽象方法待实现，符合函数式接口(指的是一个有且仅有一个抽象方法，但是可以有多个非抽象方法的接口)，因此Function接口可以用Lambda表达式——这个方法就是apply。

从源码可以看出，入参和出参类型，用泛型动态指定。apply的具体逻辑就相当于是入参转化为出参的具体逻辑。也就相当于是y = f(x)这个里面的，映射法则f。具体逻辑需要我们用匿名内部类或者Lambda，写方法体来实现。因此这个接口又叫函数型接口。

下面我们来用代码举栗如何使用Function接口：

public class FunctionTest {

    public static void main(String[] args) {

        // 如果入参为null，则回参为0，否则返回入参的值作为出参
        Function<Integer, Integer> function1 = s -> s == null ? 0 : s;

        // 将入参的值+1后作为回参返回
        Function<Integer, Integer> function2 = s -> s + 1;

        // 如果入参为null，则回参为""，否则返回入参的值作为出参
        Function<String, String> function3 = s -> s == null ? "空的" : s;

        System.out.println(function1.apply(null));
        System.out.println(function1.apply(100));

        System.out.println(function2.apply(10));

        System.out.println(function3.apply(null));
        System.out.println(function3.apply("hello world!"));
        
        // andThen是先执行前面的操作，然后执行andThen之后的操作
        Function<Integer, Integer> first = x -> x * x;
        Function<Integer, Integer> after = y -> y * 2;

        System.out.println(first.apply(3));
        System.out.println(after.apply(3));
        int res = first.andThen(after).apply(4);
        System.out.println(res);
    }
}

0
100
11
空的
hello world!
9
6
32

从上面的栗子我们可以看出：

Java把这些映射规则，也就是y = f(x)中的【f】抽象成了这个Function接口的apply逻辑。然后x和y，自变量和因变量，也就是入参出参，Java使用了扩展性更强的泛型参数类型，而不是固定Object入参出参。因为固定Object的话还要涉及到类型转换，还有可能报ClassCast异常，很麻烦

再看一个栗子：

/**
 * @author vchicken
 * @version 1.0
 * @description FunctionTest
 * @date 2022/11/10 12:10:06
 */
public class FunctionTest<T,R> {

    public static void main(String[] args) {
        FunctionTest<Integer, Integer> functionTest1 = new FunctionTest<>();
        System.out.println(functionTest1.functionTest(null, s -> s == null ? 0 : s));
        System.out.println(functionTest1.functionTest(100, s -> s == null ? 0 : s));

        System.out.println(functionTest1.functionTest(10, s -> s + 1));

        FunctionTest<String, String> functionTest2 = new FunctionTest<>();
        System.out.println(functionTest2.functionTest(null, s -> s == null ? "空的" : s));
        System.out.println(functionTest2.functionTest("hello world!", s -> s == null ? "空的" : s));
    }

    public R functionTest(T in,Function<T,R> function){
        return function.apply(in);
    }
}

执行结果：

0
100
11
空的
hello world!

结合两个栗子我们可以看出来：

我们可以使用Function接口来将同一个方法的处理逻辑抽象出来，在调用方法的时候，将处理逻辑以Lambda表达式的形式传入，实现同一个方法可以处理不同的代码逻辑，而且使用泛型来表示方法的出入参，可以避免不必要的类型转换和异常发生。@vchicken

Function接口在JDK中的应用

在JDK1.8中的新属性Stream中，就使用到了Function接口，看下面的源码：

通过一个例子来看看怎样使用map这个接口

public static void main(String[] args) {
        Stream<Integer> stream = Stream.of(-1,0,1,2,3,4);
        Stream<Integer> stream1 = stream.map(integer -> integer + 1);
        stream1.forEach(System.out::println);
    }

执行结果：

0
1
2
3
4
5

案例：将数组中的数，依次平方，等到一个一个新的数组

List<Integer> myList = new ArrayList<>();
        myList.add(-2);
        myList.add(0);
        myList.add(1);
        myList.add(3);
        myList.add(5);
        myList.add(7);
        List<Integer> collect = myList.stream().map(integer -> integer*integer).collect(Collectors.toList());
        collect.forEach(System.out::println);

执行结果：

4
0
1
9
25
49

2.Consumer接口

什么是Consumer接口？

从源码可以看出，Consumer与Function类似，只有一个accept抽象方法待实现，只不过唯一的区别是，Consumer的accept使用void修饰，没有返回值，而Function有返回值。

Consumer接口又称为消费型接口，顾名思义，入参传入后，被accept方法消费掉了，什么都没得到。

举个栗子：

    public static void main(String[] args) {
        Consumer<Object> consumer1 = new Consumer<Object>() {
            @Override
            public void accept(Object o) {
                System.out.println("这次消费了:" + o.toString());
            }
        };

        consumer1.accept("100w元在双十一！这下穷死了！");

        Consumer<String> consumer2 = s -> System.out.println("这次消费了:" + s);

        consumer2.accept("120w元在双十二！又穷死了！");
    }

执行结果：

这次消费了:100w元在双十一！这下穷死了！
这次消费了:120w元在双十二！又穷死了！

同样的，我们可以提取公共方法为：

/**
 * @author vchicken
 * @version 1.0
 * @description ComsumerTest
 * @date 2022/11/10 17:14:11
 */
public class ConsumerTest<T> {

    public static void main(String[] args) {

        ConsumerTest<String> consumerTest = new ConsumerTest<>();
        consumerTest.accept("100w元在双十一！这下穷死了！", s -> System.out.println("这次消费了:" + s));
        consumerTest.accept("120w元在双十二！又穷死了！", s -> System.out.println("这次消费了:" + s));

    }

    public void accept(T in, Consumer<? super T> consumer) {
        consumer.accept(in);
    }
}

执行结果：

这次消费了:100w元在双十一！这下穷死了！
这次消费了:120w元在双十二！又穷死了！

Consumer接口在JDK中的应用

同样的，我们以Stream中的forEach为例，看下面的例子：

 Stream<Integer> stream = Stream.of(-1,0,1,2,3,4);
 stream.forEach(s-> System.out.println(s));

执行结果：

-1
0
1
2
3
4

同样的我们还可以使用方法引用来打印，效果一致

stream.forEach(System.out::println);

对于方法引用不了解的亲，也可以阅读这篇文章Java8 新特性 - 方法引用 @vchicken

3.Suppiler接口

什么是Suppiler接口？

既然我们上面说到了Consumer为消费型接口，按照惯例，那肯定有生产型接口或者也可以成为供给型接口——Supplier接口，看下图源码：

由源码我们可以看出，Supplier接口只有一个待实的get方法，属于无参有返回值的抽象方法。下面看一个例子：

 public static void main(String[] args) {

        // 生成一个字符串
        Supplier<String> supplier1 = () -> "abcde";

        // 生成一个随机数
        Supplier<Integer> supplier2 = () -> new Random().nextInt(10);

        // 产生一个运行时异常
        Supplier<RuntimeException> supplier3 = () -> new RuntimeException();

        System.out.println(supplier1.get());
        System.out.println(supplier2.get().intValue());
        System.out.println(supplier3.get());
    }

执行结果：

abcde
2
java.lang.RuntimeException

Supplier接口在JDK中的应用

generate方法返回一个无限连续的无序流，其中每个元素由提供的供应商(Supplier)生成。generate方法用于生成常量流和随机元素流。看下面例子：

public static void main(String[] args) {

        // 生成随机数
        Stream.generate(() -> new Random().nextInt(10));
        stream.forEach(System.out::println);

        // 生成随机布尔流
        Stream.generate(() -> new Random().nextBoolean())
                .forEach(System.out::println);

        // 生成常量流
        Stream.generate(() -> "Hello World!")
                .forEach(System.out::println);

    }

执行结果：

2
5
1
--- #略

true
false
true
--- #略

Hello World!
Hello World!
Hello World!
--- #略

由于generate返回无限连续流，为了限制流中元素的数量，我们可以使用Stream.limit方法

 public static void main(String[] args) {
	Stream.generate(() -> new Random().nextInt(10)).limit(3)
	   .forEach(e -> System.out.println(e));
	
	Stream.generate(() -> new Random().nextBoolean()).limit(3)
	   .forEach(e -> System.out.println(e));
	
	Stream.generate(() -> "Hello World!").limit(3)
	   .forEach(e -> System.out.println(e));
  }

执行结果：

3
6
3
true
false
false
Hello World!
Hello World!
Hello World!

4.Predicate接口

什么是Predicate接口？

Predicate接口又称为断言型接口，test()方法有参但是返回值类型是固定的boolean，看下面例子：

public static void main(String[] args) {
        Predicate<String> predicate = (s) -> s.length() > 0;
        
        // 测试字符串的长度是否>0
        System.out.println(predicate.test("hello"));

        // 结果取反
        System.out.println(predicate.negate().test("hello"));


        System.out.println("=====or / and======");
        System.out.println(predicate.test(""));
        // 增加或判断，二者满足其一则为true
        System.out.println(predicate.or(s -> s.equals("")).test(""));
        // 增加与判断，二者都满足则为true
        System.out.println(predicate.and(s -> s.equals("hello")).test(""));
        System.out.println(predicate.and(s -> s.equals("hello")).test("hello"));

        System.out.println("=====isEqual======");
        // 判断是否相等
        System.out.println(Predicate.isEqual("hello").test(""));
        System.out.println(Predicate.isEqual("hello").test("hello"));

        Predicate<Boolean> nonNull = Objects::nonNull;
        Predicate<Boolean> isNull = Objects::isNull;

        Predicate<String> isEmpty = String::isEmpty;
        Predicate<String> isNotEmpty = isEmpty.negate();

    }

执行结果：

true
false
=====or / and======
false
true
false
true
=====isEqual======
false
true

Predicate接口在JDK中的应用

Stream中的filter方法，用来过滤不满足条件的元素，使用Predicate传入过滤条件。看下面例子：

Stream<Integer> stream = Stream.of(-1, 0, 1, 2, 3, 4);
stream.filter(s -> s > 0).forEach(System.out::println);

执行结果：

关于JDK1.8为什么要新增这四大内置函数式接口，其实就是Java的开发者将常用于代码的一些普遍场景抽象出来成为接口，而我们可以根据实际业务需求，实现这些接口的具体逻辑。通过lambda表达式的方式，也可以使得代码更加简洁。JDK中的函数式接口还有很多，但基本都是在四大函数式接口的基础之上加以拓展，有兴趣的童鞋可以自行研究。

四大函数式接口的比较

• JDK8新特性第二篇：四大函数式接口【Function/Consumer/Supplier/Perdicate】、接口的扩展方法【default/static】