在先前的文章“ 用Java的供应商延迟执行 ”和“ Java的消费者延迟执行 “,我看着很容易地通过推迟标准Java API接受,分别在Java执行供应商 S和消费者秒。 在本文中,我将对标准JDK提供的API如何通过标准功能接口Predicate允许延迟执行进行类似的研究。 Predicate
在其Javadoc中进行了描述 ,“代表一个参数的谓词(布尔值函数)。” 换句话说, Predicate
就像JDK提供的函数一样 ,但其返回值限制为true
或false
。
标准Java API中Predicate
的最常见应用可能是在过滤器的上下文中。 这篇Predicate
中的几个示例将演示Predicate
结合过滤方法对Optional实例和Stream实例的使用。
Optional.filter(谓词)
可选类的filter(Predicate)方法的行为由其Javadoc文档以这种方式描述:“如果存在值,并且该值与给定谓词匹配,则返回描述该值的Optional
,否则返回空的Optional
。 ” 换句话说, Optional.filter(Predicate)
返回一个Optional
,如果原始Optional
为空或者应用于原始和当前Optional
的Predicate
解析为false
,则该Optional
将为空。 否则,如果原始Optional
确实具有“ present”值,并且应用于该值的Predicate
返回true
,则返回的Optional
也将具有相同的“ present”值。 下一个代码清单对此进行了说明(完整的源代码在GitHub上可用 )。
Optional.filter(Predicate)已展示
/*** Demonstrate use of {@code Optional.filter(Predicate)} on an* {@code Optional<Boolean>}.*/
public static void demonstrateOptionalFilterOnBoolean()
{out.print("\nfalse: ");getOptionalBoolean(false).filter(b -> b).ifPresent(out::print);out.print("\ntrue: ");getOptionalBoolean(true).filter(b -> b).ifPresent(out::print);out.print("\nnull: ");getOptionalBoolean(null).filter(b -> b).ifPresent(out::print);
}/*** Demonstrate use of {@code Optional.filter(Predicate)} on an* {@code Optional<Float>}.*/
public static void demonstrateOptionalFilterOnFloat()
{out.print("\n3.14: ");getOptionalFloat(3.14f).filter(f -> f > 0.0).ifPresent(out::print);out.print("\n-2.5: ");getOptionalFloat(-2.5f).filter(f -> f > 0.0).ifPresent(out::print);out.print("\nnull: ");getOptionalFloat(null).filter(f -> f > 0.0).ifPresent(out::print);
}
上面的代码清单中的两种方法演示了Optional.filter(Predicate)
在基于数值比较的lambda表达式上产生直接boolean
结果以及在lambda表达式上产生boolean
结果的用法。 在一种情况下, Predicate
是boolean
,在另一种情况下, Predicate
是数值比较。
Stream.filter(谓词)
Stream接口的方法filter(Predicate) 与同名的Optional类的方法相似 。 下一个代码清单演示了Stream.filter(Predicate)
。
展示了Stream.filter(Predicate)
/*** Demonstrates use of {@code Stream.filter(Predicate}}.*/
public static void demonstrateStreamFilter()
{final int maximum = 100;out.println("\nThe probable prime numbers between 1 and " + maximum + " are:");final Stream<BigInteger> bigIntegers = getConsecutiveBigIntegers(maximum);bigIntegers.filter(bi -> bi.isProbablePrime(100)).forEach(pp -> out.println(" " + pp));
}
上面的代码清单并不旨在演示识别Java中质数的最佳方法。 相反,它意在表明如何filter(Predicate)
可以在调用Stream
来缩小该要素Stream
,只有那些符合Predicate
。
对于我的下图Stream.filter(Predicate)
,我使用Pattern类的方便的方法asPredicate()供给的实例Predicate
要被提供给使用这两个例子Stream.filter(Predicate)
。
演示了带有Pattern.asPredicate()的Stream.filter(Predicate)
/*** Demonstrates use of {@code Pattern.asPredicate()} to provide* a {@code Predicate} that can be used with {@code Stream.filter()}.*/
public static void demonstratePatternAsPredicateInFilter()
{final long count= getPotentialTelephoneNumbers().stream().filter(PATTERN.asPredicate()).peek(out::println).count();out.println(count + " valid telephone numbers.");
}
Collection.removeIf(谓词)
Collection接口指定(并作为默认方法实现 )有用的方法removeIf(Predicate) 。 还有Collection
多个实现,它们实现了它们自己的removeIf(Predicate)
的覆盖版本,包括ArrayDeque.removeIf(Predicate) , ArrayList.removeIf(Predicate)和Vector.removeIf(Predicate) 。
下面的代码清单演示了Collection.removeIf(Predicate)
两个示例。 第一个示例使用Predicate.negate()方法取反期望的正则表达式模式,以便从集合中删除的元素是与正则表达式不匹配的元素。 第二个示例执行类似的功能,但是利用了JDK 11引入的“非”方法来执行此否定操作。
展示了带有否定的Pattern.asPredicate()的Collection.removeIf(Predicate)
/*** Demonstrates use of {@code Collection.removeIf(Predicate)}* in conjunction with {@code Predicate.negate()}.*/
public static void demonstrateCollectionRemoveIf()
{final Set<String> telephoneNumbers = new HashSet<>(getPotentialTelephoneNumbers());telephoneNumbers.removeIf(PATTERN.asPredicate().negate());out.println(telephoneNumbers);
}/*** Demonstrates use of {@code Collection.removeIf(Predicate)}* in conjunction with JDK 11-introduced {@code Predicate.not()}.*/
public static void demonstrateCollectionRemoveIfWithJdk11Not()
{final Set<String> telephoneNumbers = new HashSet<>(getPotentialTelephoneNumbers());telephoneNumbers.removeIf(not(PATTERN.asPredicate()));out.println(telephoneNumbers);
}
Stream.allMatch(谓词)
如果流中的每个元素都与提供的Predicate
相匹配,则Stream接口的方法allMatch(Predicate)返回true
。 如果甚至单个元素都不匹配Predicate
,则该方法返回false
。
展示了Stream.allMatch(Predicate)
/*** Demonstrate use of {@code Stream.allMatch(Predicate)}.*/
public static void demonstrateStreamAllMatch()
{final Set<String> names = getNames();final boolean allNamesSixDigits = names.stream().allMatch(name -> name.length() == 6);out.println("Are all names " + names + " six digits? " + allNamesSixDigits);
}
Stream.anyMatch(谓词)
所述Stream.anyMatch(谓词)方法返回true
,如果它的元素中的至少一个相匹配的Predicate
并返回false
,如果没有它的元素的匹配Predicate
。
展示了Stream.anyMatch(Predicate)
/*** Demonstrate use of {@code Stream.anyMatch(Predicate)}.*/
public static void demonstrateStreamAnyMatch()
{final Set<String> names = getNames();final boolean anyNamesSixDigits = names.stream().anyMatch(name -> name.length() == 6);out.println("Are any names " + names + " six digits? " + anyNamesSixDigits);
}
Stream.noneMatch(谓词)
所述Stream.noneMatch(谓词)方法返回true
时在流没有元素匹配Predicate
并返回false
如果流中的至少一种元素确实匹配的Predicate
。
展示了Stream.noneMatch(Predicate)
/*** Demonstrate use of {@code Stream.noneMatch(Predicate)}.*/
public static void demonstrateStreamNoneMatch()
{final Set<String> names = getNames();final boolean noNamesSixDigits = names.stream().noneMatch(name -> name.length() == 6);out.println("Are no names " + names + " six digits? " + noNamesSixDigits);final boolean noNamesFourDigits = names.stream().noneMatch(name -> name.length() == 4);out.println("Are no names " + names + " four digits? " + noNamesFourDigits);
}
Collectors.partitioningBy(谓词)
尽管还有更多使用 Predicate
JDK API ,但本文将通过讨论和使用Collectors.partitioningBy(Predicate)的示例进行总结。 这种有趣的方法将调用流的所有元素分为两组,一组与键Boolean.TRUE相关联(与Predicate
匹配的元素),另一组与键Boolean.FALSE相关联的组(没有匹配Predicate
)。 下一个代码清单利用此功能将整数分为偶数和奇数。
展示了Collectors.partitioningBy(Predicate)
/*** Demonstrate use of {@code Collectors.partitioningBy(Predicate)}.*/
public static void demonstrateCollectorsPartitioningBy()
{final Map<Boolean, List<Integer>> evensAndOdds= getConsecutiveIntegers(100).collect(Collectors.partitioningBy(integer -> integer % 2 == 0));out.println("Evens: " + evensAndOdds.get(Boolean.TRUE));out.println("Odds: " + evensAndOdds.get(Boolean.FALSE));
}
我在上面的代码示例中使用了几种“帮助程序”方法,这些在本文中未显示。 这些“帮助程序”方法以及本文中显示的所有示例都可以在GitHub上找到 。
Java的标准功能接口Predicate是内置Java功能接口Function的一个特殊版本,可以说应该得到自己的专业化,因为true
/ false
返回状态对于表示某些功能适用或不适用的条件非常有用。 这篇文章展示了JDK中的几个实例,在这些实例中, Predicate
用于确定哪些流元素适用,是否使用Optional
,并将流元素分为满足谓词的元素和不满足谓词的元素。 在此过程中,还演示了便捷方法,例如Pattern.asPredicate()和Predicate.not() 。
翻译自: https://www.javacodegeeks.com/2018/07/deferred-execution-javas-predicate.html