Predicate如何在Java 8中维护状态

Question

我正在查看此代码并尝试理解以下代码.

复制自Stuart Marks的回答

public static <T> Predicate<T> distinctByKey(Function<? super T,Object> keyExtractor) {
    Map<Object,Boolean> seen = new ConcurrentHashMap<>();
    return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
}

BigDecimal totalShare = orders.stream()
    .filter(distinctByKey(o -> o.getCompany().getId()))
    .map(Order::getShare)
    .reduce(BigDecimal.ZERO, BigDecimal::add);

我的问题是每次调用distinctByKey并生成新的ConcurrentHashMap.如何使用新的ConcurrentHashMap <>()来维护状态; ？

Answer 1

由于这是一个捕获的λ,确实是一个新的Predicate实例将被返回的所有每次通话的时间-但这些实例将共享相同的ConcurrentHashMap和Function.

顺便说一下,添加一个System.out.println内部 distinctByKey- 并看到它实际上只被调用一次.

如果您愿意用以下方式运行您的示例:

Djdk.internal.lambda.dumpProxyClasses=/Your/Path/Here

你会看到class为你的实现生成了一个Predicate.因为这是一个有状态的lambda - 它捕获了CHM和Function,它将有一个private构造函数和一个static factory method返回一个实例.因此,每一个元素穿过流管道时会出现一个不同的实例Predicate创建的-但所有这些实例将共享相同的ConcurrentHashMap和Function.

Answer 2

这看起来很混乱，但它很简单。实际发生的情况是该distinctByKey方法仅被调用一次，因此永远只有一个 的实例，ConcurrentHashMap并且它被 lambda 表达式捕获。因此，当该distinctByKey方法返回一个Predicate对象时，我们会将其应用于流的每个元素。