逐步走向响应式编程（二）-常见函数式接口- Consumer＜T＞

java8提供的Consumer也是一大常用接口，其功能正如其名，用于“消费”操作。此接口提供了两个方法，其中一个是待实现的方法accept，另一个是默认方法andThen。此接口主要用于对某数据进行处理，无需返回值的情景。接下来从以下几个方面来认识此接口。

• • 源码解析
  • 案例分析
  • • accept方法
    • andThen方法
    • 万能方法
  • 总结

package java.util.function;

import java.util.Objects;


@FunctionalInterface
public interface Consumer {

    
    void accept(T t);

    
    default Consumer andThen(Consumer after) {
        Objects.requireNonNull(after);
        return (T t) -> { accept(t); after.accept(t); };
    }
}

本案例对一个int数组进行操作int num[] = { 1, 2, 3, 4, 5, 6, 7, 8, 9 }; 另外需要借助一个决断函数checkData：

 private static  boolean checkData(T t, Predicate predicate) {
        return predicate.test(t);
    }

打印数组中的偶数值

//实现偶数值的消费逻辑
Consumer evenConsumer = t -> {
            for (int i : t) {
                if (checkData(i, k -> k % 2 == 0)) {
                    System.out.print("=" + i);
                }
            }
        };
//开始消费
evenConsumer.accept(num)；
//最终结果
=2=4=6=8

同一组数据实现不同的处理方法，就需要使用此方法。例如在上面的基础之前还需要打印>2的数

//实现>2的值消费逻辑
Consumer moreThan2 = t -> {
            for (int i : t) {
                if (checkData(i, k -> k > 2)) {
                    System.out.println("++" + i);
                }
            }
        };
//开始消费        
 evenConsumer.andThen(moreThan2).accept(num);  
//最终结果
=2=4=6=8
++3++4++5++6++7++8++9 

需要注意的一点就是，andThen方法只是加了一种消费逻辑，第一次消费不会影响第二次消费

本人在此用consumer的时候，通常用一个方法对消费逻辑和消费对象包装在一个方法中，方便重用

public static  void consumeData(T t, Consumer consumer) {
        consumer.accept(t);
    }

上述两个例子可以调用此方法

//打印偶数值
类名.consumeData(num, evenConsumer);
//打印>2的值
类名.consumeData(num, moreThan2);
//两者都打印
类名.consumeData(num, evenConsumer.andThen(moreThan2));

另外java8 还提供了很多其他的Consumer接口,用法基本一致：

内容很简单，所有的消费最终都会交给accept处理，因为accept是唯一需要实现的接口，也就是说此方法实现了消费逻辑。在java8的Stream中，Consumer使用很广泛，后续的博文中会一一介绍。最后希望本文能帮助大家，祝大家在IT之路上少走弯路，一路绿灯不堵车，测试一性通过，bug秒解！