JAVA

Java8之Consumer、Supplier

转载:https://zhuanlan.zhihu.com/p/76340256

今天我们还讲讲Consumer、Supplier、Predicate、Function这几个接口的用法,在 Java8 的用法当中,这几个接口虽然没有明目张胆的使用,但是,却是润物细无声的。为什么这么说呢?

这几个接口都在 java.util.function 包下的,分别是Consumer(消费型)、supplier(供给型)、predicate(谓词型)、function(功能性),相信有了后面的解释,你应该非常清楚这个接口的功能了。

那么,下面,我们从具体的应用场景来讲讲这个接口的用法!

1 Consumer接口


从字面意思上我们就可以看得出啦,consumer接口就是一个消费型的接口,通过传入参数,然后输出值,就是这么简单,Java8 的一些方法看起来很抽象,其实,只要你理解了就觉得很好用,并且非常的简单。

我们下面就先看一个例子,然后再来分析这个接口。

1.1 Consumer实例

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
/**
* consumer接口测试
*/
@Test
public void test_Consumer() {
//① 使用consumer接口实现方法
Consumer<String> consumer = new Consumer<String>() {
@Override
public void accept(String s) {
System.out.println(s);
}
};
Stream<String> stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff");
stream.forEach(consumer);
System.out.println("********************");
//② 使用lambda表达式,forEach方法需要的就是一个Consumer接口
stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff");
Consumer<String> consumer1 = (s) -> System.out.println(s);//lambda表达式返回的就是一个Consumer接口
stream.forEach(consumer1);
//更直接的方式
//stream.forEach((s) -> System.out.println(s));
System.out.println("********************");
//③ 使用方法引用,方法引用也是一个consumer
stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff");
Consumer consumer2 = System.out::println;
stream.forEach(consumer);
//更直接的方式
//stream.forEach(System.out::println);
}
/** * consumer接口测试 */ @Test public void test_Consumer() { //① 使用consumer接口实现方法 Consumer<String> consumer = new Consumer<String>() { @Override public void accept(String s) { System.out.println(s); } }; Stream<String> stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff"); stream.forEach(consumer); System.out.println("********************"); //② 使用lambda表达式,forEach方法需要的就是一个Consumer接口 stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff"); Consumer<String> consumer1 = (s) -> System.out.println(s);//lambda表达式返回的就是一个Consumer接口 stream.forEach(consumer1); //更直接的方式 //stream.forEach((s) -> System.out.println(s)); System.out.println("********************"); //③ 使用方法引用,方法引用也是一个consumer stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff"); Consumer consumer2 = System.out::println; stream.forEach(consumer); //更直接的方式 //stream.forEach(System.out::println); }
/**
     * consumer接口测试
     */
    @Test
    public void test_Consumer() {
        //① 使用consumer接口实现方法
        Consumer<String> consumer = new Consumer<String>() {

            @Override
            public void accept(String s) {
                System.out.println(s);
            }
        };
        Stream<String> stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff");
        stream.forEach(consumer);

        System.out.println("********************");

        //② 使用lambda表达式,forEach方法需要的就是一个Consumer接口
        stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff");
        Consumer<String> consumer1 = (s) -> System.out.println(s);//lambda表达式返回的就是一个Consumer接口
        stream.forEach(consumer1);
        //更直接的方式
        //stream.forEach((s) -> System.out.println(s));
        System.out.println("********************");

        //③ 使用方法引用,方法引用也是一个consumer
        stream = Stream.of("aaa", "bbb", "ddd", "ccc", "fff");
        Consumer consumer2 = System.out::println;
        stream.forEach(consumer);
        //更直接的方式
        //stream.forEach(System.out::println);
    }

输出结果

1.2 实例分析

consumer接口分析

在代码①中,我们直接创建 Consumer 接口,并且实现了一个名为 accept 的方法,这个方法就是这个接口的关键了。

我们看一下 accept 方法;这个方法传入一个参数,不返回值。当我们发现 forEach 需要一个 Consumer 类型的参数的时候,传入之后,就可以输出对应的值了。

② lambda 表达式作为 consumer

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
Consumer<String> consumer1 = (s) -> System.out.println(s);//lambda表达式返回的就是一个Consumer接口
Consumer<String> consumer1 = (s) -> System.out.println(s);//lambda表达式返回的就是一个Consumer接口
Consumer<String> consumer1 = (s) -> System.out.println(s);//lambda表达式返回的就是一个Consumer接口

在上面的代码中,我们使用下面的 lambda 表达式作为 Consumer。仔细的看一下你会发现,lambda 表达式返回值就是一个 Consumer;所以,你也就能够理解为什么 forEach 方法可以使用 lamdda 表达式作为参数了吧。

③ 方法引用作为 consumer

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
Consumer consumer2 = System.out::println;
Consumer consumer2 = System.out::println;
Consumer consumer2 = System.out::println;

在上面的代码中,我们用了一个方法引用的方式作为一个 Consumer ,同时也可以传给 forEach 方法。

1.3 其他 Consumer 接口

除了上面使用的 Consumer 接口,还可以使用下面这些 Consumer 接口。
IntConsumer、DoubleConsumer、LongConsumer、BiConsumer,使用方法和上面一样。

1.4 Consumer 总结

看完上面的实例我们可以总结为几点。

① Consumer是一个接口,并且只要实现一个 accept 方法,就可以作为一个“消费者”输出信息。
② 其实,lambda 表达式、方法引用的返回值都是 Consumer 类型,所以,他们能够作为 forEach 方法的参数,并且输出一个值。

2 Supplier 接口


Supplier 接口是一个供给型的接口,其实,说白了就是一个容器,可以用来存储数据,然后可以供其他方法使用的这么一个接口,是不是很明白了,如果还是不明白,看看下面的例子,一定彻底搞懂!

Java 8中引入的Supplier表示一个供应商,代表一个函数,这个函数不需要任何输入参数,只返回一个我们定义好的数据类型的输出结果。

该接口定义了一个函数式方法,即get()方法,用于获取输出结果,如下所示:

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
@FunctionalInterface
public interface Supplier<T> {
T get();
}
@FunctionalInterface public interface Supplier<T> { T get(); }
@FunctionalInterface
public interface Supplier<T> {

    T get();
}

其中,@FunctionalInterface注解表示该接口是函数式接口,即该接口只能定义一个抽象的方法。

2.1 Supplier实例

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
**
* Supplier接口测试,supplier相当一个容器或者变量,可以存储值
*/
@Test
public void test_Supplier() {
//① 使用Supplier接口实现方法,只有一个get方法,无参数,返回一个值
Supplier<Integer> supplier = new Supplier<Integer>() {
@Override
public Integer get() {
//返回一个随机值
return new Random().nextInt();
}
};
System.out.println(supplier.get());
System.out.println("********************");
//② 使用lambda表达式,
supplier = () -> new Random().nextInt();
System.out.println(supplier.get());
System.out.println("********************");
//③ 使用方法引用
Supplier<Double> supplier2 = Math::random;
System.out.println(supplier2.get());
** * Supplier接口测试,supplier相当一个容器或者变量,可以存储值 */ @Test public void test_Supplier() { //① 使用Supplier接口实现方法,只有一个get方法,无参数,返回一个值 Supplier<Integer> supplier = new Supplier<Integer>() { @Override public Integer get() { //返回一个随机值 return new Random().nextInt(); } }; System.out.println(supplier.get()); System.out.println("********************"); //② 使用lambda表达式, supplier = () -> new Random().nextInt(); System.out.println(supplier.get()); System.out.println("********************"); //③ 使用方法引用 Supplier<Double> supplier2 = Math::random; System.out.println(supplier2.get());
**
     * Supplier接口测试,supplier相当一个容器或者变量,可以存储值
     */
    @Test
    public void test_Supplier() {
        //① 使用Supplier接口实现方法,只有一个get方法,无参数,返回一个值
        Supplier<Integer> supplier = new Supplier<Integer>() {
            @Override
            public Integer get() {
                //返回一个随机值
                return new Random().nextInt();
            }
        };

        System.out.println(supplier.get());

        System.out.println("********************");

        //② 使用lambda表达式,
        supplier = () -> new Random().nextInt();
        System.out.println(supplier.get());
        System.out.println("********************");

        //③ 使用方法引用
        Supplier<Double> supplier2 = Math::random;
        System.out.println(supplier2.get());

输出结果

2.2 实例分析

① Supplier接口分析

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
Supplier<Integer> supplier = new Supplier<Integer>() {
@Override
public Integer get() {
//返回一个随机值
return new Random().nextInt();
}
};
Supplier<Integer> supplier = new Supplier<Integer>() { @Override public Integer get() { //返回一个随机值 return new Random().nextInt(); } };
Supplier<Integer> supplier = new Supplier<Integer>() {
            @Override
            public Integer get() {
                //返回一个随机值
                return new Random().nextInt();
            }
        };

看一下这段代码,我们通过创建一个 Supplier 对象,实现了一个 get 方法,这个方法无参数,返回一个值;所以,每次使用这个接口的时候都会返回一个值,并且保存在这个接口中,所以说是一个容器

② lambda表达式作为 Supplier

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
//② 使用lambda表达式,
supplier = () -> new Random().nextInt();
System.out.println(supplier.get());
System.out.println("********************");
//② 使用lambda表达式, supplier = () -> new Random().nextInt(); System.out.println(supplier.get()); System.out.println("********************");
//② 使用lambda表达式,
        supplier = () -> new Random().nextInt();
        System.out.println(supplier.get());
        System.out.println("********************");

上面的这段代码,我们使用 lambda 表达式返回一个 Supplier类型的接口,然后,我们调用 get 方法就可以获取这个值了。

③ 方法引用作为 Supplier

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
//③ 使用方法引用
Supplier<Double> supplier2 = Math::random;
System.out.println(supplier2.get());
//③ 使用方法引用 Supplier<Double> supplier2 = Math::random; System.out.println(supplier2.get());
//③ 使用方法引用
        Supplier<Double> supplier2 = Math::random;
        System.out.println(supplier2.get());

方法引用也是返回一个Supplier类型的接口。

2.3 Supplier 实例2

我们看完第一个实例之后,我们应该有一个了解了,下面再看一个。

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
/**
* Supplier接口测试2,使用需要Supplier的接口方法
*/
@Test
public void test_Supplier2() {
Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5);
//返回一个optional对象
Optional<Integer> first = stream.filter(i -> i > 4)
.findFirst();
//optional对象有需要Supplier接口的方法
//orElse,如果first中存在数,就返回这个数,如果不存在,就放回传入的数
System.out.println(first.orElse(1));
System.out.println(first.orElse(7));
System.out.println("********************");
Supplier<Integer> supplier = new Supplier<Integer>() {
@Override
public Integer get() {
//返回一个随机值
return new Random().nextInt();
}
};
//orElseGet,如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值
System.out.println(first.orElseGet(supplier));
}
/** * Supplier接口测试2,使用需要Supplier的接口方法 */ @Test public void test_Supplier2() { Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5); //返回一个optional对象 Optional<Integer> first = stream.filter(i -> i > 4) .findFirst(); //optional对象有需要Supplier接口的方法 //orElse,如果first中存在数,就返回这个数,如果不存在,就放回传入的数 System.out.println(first.orElse(1)); System.out.println(first.orElse(7)); System.out.println("********************"); Supplier<Integer> supplier = new Supplier<Integer>() { @Override public Integer get() { //返回一个随机值 return new Random().nextInt(); } }; //orElseGet,如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值 System.out.println(first.orElseGet(supplier)); }
/**
     * Supplier接口测试2,使用需要Supplier的接口方法
     */
    @Test
    public void test_Supplier2() {
        Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5);
        //返回一个optional对象
        Optional<Integer> first = stream.filter(i -> i > 4)
                .findFirst();

        //optional对象有需要Supplier接口的方法
        //orElse,如果first中存在数,就返回这个数,如果不存在,就放回传入的数
        System.out.println(first.orElse(1));
        System.out.println(first.orElse(7));

        System.out.println("********************");

        Supplier<Integer> supplier = new Supplier<Integer>() {
            @Override
            public Integer get() {
                //返回一个随机值
                return new Random().nextInt();
            }
        };

        //orElseGet,如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值
        System.out.println(first.orElseGet(supplier));
    }

输出结果

代码分析

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
Optional<Integer> first = stream.filter(i -> i > 4)
.findFirst();
Optional<Integer> first = stream.filter(i -> i > 4) .findFirst();
Optional<Integer> first = stream.filter(i -> i > 4)
                .findFirst();

使用这个方法获取到一个 Optional 对象,然后,在 Optional 对象中有 orElse 方法 和 orElseGet 是需要一个 Supplier 接口的。

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
//optional对象有需要Supplier接口的方法
//orElse,如果first中存在数,就返回这个数,如果不存在,就放回传入的数
System.out.println(first.orElse(1));
System.out.println(first.orElse(7));
System.out.println("********************");
Supplier<Integer> supplier = new Supplier<Integer>() {
@Override
public Integer get() {
//返回一个随机值
return new Random().nextInt();
}
};
//orElseGet,如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值
System.out.println(first.orElseGet(supplier));
//optional对象有需要Supplier接口的方法 //orElse,如果first中存在数,就返回这个数,如果不存在,就放回传入的数 System.out.println(first.orElse(1)); System.out.println(first.orElse(7)); System.out.println("********************"); Supplier<Integer> supplier = new Supplier<Integer>() { @Override public Integer get() { //返回一个随机值 return new Random().nextInt(); } }; //orElseGet,如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值 System.out.println(first.orElseGet(supplier));
//optional对象有需要Supplier接口的方法
        //orElse,如果first中存在数,就返回这个数,如果不存在,就放回传入的数
        System.out.println(first.orElse(1));
        System.out.println(first.orElse(7));

        System.out.println("********************");

        Supplier<Integer> supplier = new Supplier<Integer>() {
            @Override
            public Integer get() {
                //返回一个随机值
                return new Random().nextInt();
            }
        };

        //orElseGet,如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值
        System.out.println(first.orElseGet(supplier));
  • orElse:如果first中存在数,就返回这个数,如果不存在,就放回传入的数
  • orElseGet:如果first中存在数,就返回这个数,如果不存在,就返回supplier返回的值

Supplier的常见用法

在Java 8中,Supplier比较常用的用处有两个:

1. 延迟计算

例如,在下面的示例中,我们使用Supplier来延迟计算,只有在计算结果被真正需要时才会被计算。

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
Supplier<Integer> integerSupplier = () -> {
System.out.println("正在计算...");
return 10;
};
System.out.println("开始运行...");
System.out.println(integerSupplier.get());
Supplier<Integer> integerSupplier = () -> { System.out.println("正在计算..."); return 10; }; System.out.println("开始运行..."); System.out.println(integerSupplier.get());
Supplier<Integer> integerSupplier = () -> {
            System.out.println("正在计算...");
            return 10;
        };

        System.out.println("开始运行...");
        System.out.println(integerSupplier.get());

输出结果为:

可见,只有在integerSupplier.get()方法调用时,计算结果才真正被计算。

2. 用于模拟生产数据

例如,在下面的示例中,我们使用Supplier来生成10个随机数:

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
Supplier<Integer> integerSupplier = () -> {
Random random = new Random();
return random.nextInt(100);
};
for (int i = 0; i < 10; i++) {
System.out.println(integerSupplier.get());
}
Supplier<Integer> integerSupplier = () -> { Random random = new Random(); return random.nextInt(100); }; for (int i = 0; i < 10; i++) { System.out.println(integerSupplier.get()); }
Supplier<Integer> integerSupplier = () -> {
            Random random = new Random();
            return random.nextInt(100);
        };

        for (int i = 0; i < 10; i++) {
            System.out.println(integerSupplier.get());
        }

输出结果为:

可见,通过Supplier我们可以灵活地生成数据。