带有过滤条件工作流程的 Java 8 流

Question

在带有过滤条件的 Java 8 流中，集合中的每个元素都被传递给过滤器以检查条件。在这里，我正在编写两种不同的过滤条件并给出不同的工作流程。

public static void main(String[] args) {

    List<String> asList = Arrays.asList("a", "b", "c", "d", "e", "a", "b", "c");

    //line 1

    asList.stream().map(s -> s).filter(distinctByKey(String::toString)).forEach(System.out::println);

    Predicate<String> strPredicate = (a) -> {

        System.out.println("inside strPredicate method--");

        return a.startsWith("a");

    };

    //line 2

    asList.stream().filter(strPredicate).forEach(System.out::println);

}

public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {

    System.out.println("inside distinctByKey method...");

    Set<Object> seen = ConcurrentHashMap.newKeySet();

    return t -> seen.add(keyExtractor.apply(t));

}

在上面的示例代码中，语句第 1 行过滤条件只执行一次，但第 2 行正在为集合输出中的每个元素执行。

我认为该distinctByKey方法会为集合中的每个元素执行，但事实并非如此。为什么 ？

另外，Set对象引用变量seen是仅执行一次？流量如何运作？

Answer 1

distinctByKey是一个 lambda 工厂方法。它正在返回一个Predictate<T>.所以当你执行时：filter(distinctByKey(String::toString))你实际上是distinctByKey先调用方法，然后返回一个Predicate. 然后为每个元素执行该谓词。只是工厂函数只会执行一次。移动System.out.println返回的 lambda 内部时，您将获得所需的打印语句：public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {&nbsp; &nbsp; System.out.println("inside distinctByKey method...");&nbsp; &nbsp; Set<Object> seen = ConcurrentHashMap.newKeySet();&nbsp; &nbsp; return t -> {&nbsp; &nbsp; &nbsp; &nbsp; System.out.println("inside distinctByKey.lambda method... ");&nbsp; &nbsp; &nbsp; &nbsp; return seen.add(keyExtractor.apply(t));&nbsp; &nbsp; };}

Answer 2

这seen是拍摄由lambda表达式和缓存的拉姆达里面，一旦你的回报Predicate-在Predicate::test将与被多次调用同一实例的seen