Java函数式编程：高级技术与Stream API

Java函数式编程：高级水平

Java中的函数式编程（FP）已不再仅仅是一种流行趋势——自版本8起，它已成为现代语言不可或缺的一部分。对于已经掌握基本Lambda表达式和Stream API的开发者来说，接下来需要理解更深入的概念：单子、函数组合、惰性求值和不可变数据结构。本文致力于介绍Java中高级函数式编程技术，这些技术将帮助您编写更简洁、可预测且并行安全的代码。

1. 函数组合与柯里化

在Java中，函数式接口Function、Predicate和Consumer提供了用于组合的默认方法：andThen()和compose()。这使得无需创建中间变量即可构建转换链。

组合示例：

import java.util.function.Function;

public class FunctionComposition {    public static void main(String[] args) {        Function<String, String> trim = String::trim;        Function<String, String> toUpper = String::toUpperCase;        Function<String, String> addExclamation = s -> s + "!";

        // 组合：trim -> toUpper -> addExclamation        Function<String, String> process = trim.andThen(toUpper).andThen(addExclamation);

        String result = process.apply("  hello world  ");        System.out.println(result); // HELLO WORLD!    }}

柯里化——是将一个多参数函数转换为一系列单参数函数的过程。在Java中，可以通过嵌套Lambda表达式来模拟：

import java.util.function.Function;

public class CurryingExample {    // 普通函数    static int add(int a, int b) { return a + b; }

    // 柯里化版本    static Function<Integer, Function<Integer, Integer>> curriedAdd = a -> b -> a + b;

    public static void main(String[] args) {        // 部分应用        Function<Integer, Integer> add5 = curriedAdd.apply(5);        System.out.println(add5.apply(3)); // 8        System.out.println(add5.apply(10)); // 15    }}

柯里化有助于基于通用模板创建特化函数，特别是在处理配置时非常有用。

2. Stream API高级应用

Java中的Stream API不仅仅是循环的替代品。理解其高级功能可以显著提高代码的性能和可读性。

2.1. 并行流与分割器

并行流使用ForkJoinPool。然而，其效率取决于数据大小和操作性质。为了自定义并行化控制，可以使用Spliterator。

import java.util.Spliterator;import java.util.stream.Stream;import java.util.stream.StreamSupport;

public class CustomSpliterator {    public static void main(String[] args) {        // 使用自定义分割器从迭代器创建流        Spliterator<Integer> spliterator = new Spliterator<>() {            int current = 0;            @Override            public boolean tryAdvance(java.util.function.Consumer<? super Integer> action) {                if (current < 100) {                    action.accept(current++);                    return true;                }                return false;            }            @Override            public Spliterator<Integer> trySplit() {                // 最简单的分割                int mid = current + 50;                if (mid >= 100) return null;                Spliterator<Integer> prefix = new RangeSpliterator(curre