java consumer

简介

在Java语言中，Consumer是一种函数式接口，用于表示接受一个输入参数，并且不返回任何结果的操作。在函数式编程中，Consumer通常用于处理一些具体的操作，例如打印输出、文件写入、网络请求等。

Consumer接口定义如下：

@FunctionalInterface
public interface Consumer<T> {
    void accept(T t);
}

Consumer接口只有一个抽象方法accept()，该方法接受一个参数，然后执行一些操作。

Consumer的使用

Consumer接口的使用非常灵活，可以直接使用Lambda表达式进行实现，也可以将其作为参数传递给其他方法。

使用Lambda表达式

使用Lambda表达式来实现Consumer接口非常简洁。下面是一个示例代码，展示如何使用Consumer接口打印输出一个字符串：

Consumer<String> printConsumer = str -> System.out.println(str);
printConsumer.accept("Hello, Consumer!");

运行结果：

Hello, Consumer!

传递Consumer作为参数

Consumer接口还可以将其作为参数传递给其他方法，在方法中执行具体的操作。下面是一个示例代码，展示如何传递Consumer作为参数，并在方法中执行Consumer的操作：

public class ConsumerExample {
    public static void main(String[] args) {
        List<String> stringList = Arrays.asList("Apple", "Orange", "Banana");
        processList(stringList, str -> System.out.println(str));
    }

    public static void processList(List<String> list, Consumer<String> consumer) {
        for (String str : list) {
            consumer.accept(str);
        }
    }
}

运行结果：

Apple
Orange
Banana

Consumer的组合

在一些场景下，可能需要将多个Consumer组合起来执行一系列的操作。Java 8中新增了andThen()方法，可以用于将两个Consumer组合起来，依次执行。

下面是一个示例代码，展示如何使用andThen()方法将多个Consumer组合起来执行：

Consumer<String> printConsumer = str -> System.out.println(str);
Consumer<String> upperCaseConsumer = str -> System.out.println(str.toUpperCase());

Consumer<String> combinedConsumer = printConsumer.andThen(upperCaseConsumer);
combinedConsumer.accept("hello");

运行结果：

hello
HELLO

andThen()方法会依次执行两个Consumer的操作。

Consumer的异常处理

在实际应用中，可能会遇到执行Consumer操作时发生异常的情况。为了能够处理这些异常，Java 8中引入了java.util.function.Consumer的衍生接口java.util.function.ConsumerEx和java.util.function.ConsumerWithException。

下面是一个示例代码，展示如何在Consumer操作中处理异常：

@FunctionalInterface
public interface ConsumerWithException<T, E extends Exception> {
    void accept(T t) throws E;
}

public class ConsumerExample {
    public static void main(String[] args) {
        List<Integer> numberList = Arrays.asList(1, 2, 3, 4, 5);
        processList(numberList, (Integer num) -> {
            try {
                int result = 10 / num;
                System.out.println(result);
            } catch (ArithmeticException e) {
                System.out.println("Error: " + e.getMessage());
            }
        });
    }

    public static <T> void processList(List<T> list, ConsumerWithException<T, Exception> consumer) {
        for (T item : list) {
                consumer.accept(item);
        }
    }
}

运行结果：