• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

Java 8 Stream.distinct() 列表去重示例

java 来源:小慧琪 1次浏览

 

Java 8 Stream.distinct() 示例

 

    在这篇文章里,我们将提供Java8 Stream distinct()示例。 distinct()返回由该流的不同元素组成的流。distinct()是Stream接口的方法。distinct()使用hashCode()和equals()方法来获取不同的元素。因此,我们的类必须实现hashCode()和equals()方法。如果distinct()正在处理有序流,那么对于重复元素,将保留以遭遇顺序首先出现的元素,并且以这种方式选择不同元素是稳定的。在无序流的情况下,不同元素的选择不一定是稳定的,是可以改变的。distinct()执行有状态的中间操作。在有序流的并行流的情况下,保持distinct()的稳定性是需要很高的代价的,因为它需要大量的缓冲开销。如果我们不需要保持遭遇顺序的一致性,那么我们应该可以使用通过BaseStream.unordered()方法实现的无序流。

1. Stream.distinct()

distinct()方法的声明如下:

Stream<T> distinct()

它是Stream接口的方法。在此示例中,我们有一个包含重复元素的字符串数据类型列表

DistinctSimpleDemo.java

 
  1. package com.concretepage;

  2. import java.util.Arrays;

  3. import java.util.List;

  4. import java.util.stream.Collectors;

  5. public class DistinctSimpleDemo {

  6. public static void main(String[] args) {

  7. List<String> list = Arrays.asList("AA", "BB", "CC", "BB", "CC", "AA", "AA");

  8. long l = list.stream().distinct().count();

  9. System.out.println("No. of distinct elements:"+l);

  10. String output = list.stream().distinct().collect(Collectors.joining(","));

  11. System.out.println(output);

  12. }

  13. }

Output 

 
  1. No. of distinct elements:3

  2. AA,BB,CC

2. Stream.distinct() with List of Objects

在此示例中,我们有一个Book对象列表。 为了对列表进行去重,该类将重写hashCode()和equals()。

Book.java

 
  1. package com.concretepage;

  2. public class Book {

  3. private String name;

  4. private int price;

  5. public Book(String name, int price) {

  6. this.name = name;

  7. this.price = price;

  8. }

  9. public String getName() {

  10. return name;

  11. }

  12. public int getPrice() {

  13. return price;

  14. }

  15. @Override

  16. public boolean equals(final Object obj) {

  17. if (obj == null) {

  18. return false;

  19. }

  20. final Book book = (Book) obj;

  21. if (this == book) {

  22. return true;

  23. } else {

  24. return (this.name.equals(book.name) && this.price == book.price);

  25. }

  26. }

  27. @Override

  28. public int hashCode() {

  29. int hashno = 7;

  30. hashno = 13 * hashno + (name == null ? 0 : name.hashCode());

  31. return hashno;

  32. }

  33. }

DistinctWithUserObjects.java

 
  1. package com.concretepage;

  2. import java.util.ArrayList;

  3. import java.util.List;

  4. public class DistinctWithUserObjects {

  5. public static void main(String[] args) {

  6. List<Book> list = new ArrayList<>();

  7. {

  8. list.add(new Book("Core Java", 200));

  9. list.add(new Book("Core Java", 200));

  10. list.add(new Book("Learning Freemarker", 150));

  11. list.add(new Book("Spring MVC", 300));

  12. list.add(new Book("Spring MVC", 300));

  13. }

  14. long l = list.stream().distinct().count();

  15. System.out.println("No. of distinct books:"+l);

  16. list.stream().distinct().forEach(b -> System.out.println(b.getName()+ "," + b.getPrice()));

  17. }

  18. }

Output 

 

 
  1. No. of distinct books:3

  2. Core Java,200

  3. Learning Freemarker,150

  4. Spring MVC,300

3. Distinct by Property

distinct()不提供按照属性对对象列表进行去重的直接实现。它是基于hashCode()和equals()工作的。如果我们想要按照对象的属性,对对象列表进行去重,我们可以通过其它方法来实现。如下代码段所示:

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

  2. Map<Object,Boolean> seen = new ConcurrentHashMap<>();

  3. return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;

  4. }

上面的方法可以被Stream接口的 filter()接收为参数,如下所示:

list.stream().filter(distinctByKey(b -> b.getName())); 

distinctByKey()方法返回一个使用ConcurrentHashMap 来维护先前所见状态的 Predicate 实例,如下是一个完整的使用对象属性来进行去重的示例。

DistinctByProperty.java

 
  1. package com.concretepage;

  2. import java.util.ArrayList;

  3. import java.util.List;

  4. import java.util.Map;

  5. import java.util.concurrent.ConcurrentHashMap;

  6. import java.util.function.Function;

  7. import java.util.function.Predicate;

  8. public class DistinctByProperty {

  9. public static void main(String[] args) {

  10. List<Book> list = new ArrayList<>();

  11. {

  12. list.add(new Book("Core Java", 200));

  13. list.add(new Book("Core Java", 300));

  14. list.add(new Book("Learning Freemarker", 150));

  15. list.add(new Book("Spring MVC", 200));

  16. list.add(new Book("Hibernate", 300));

  17. }

  18. list.stream().filter(distinctByKey(b -> b.getName()))

  19. .forEach(b -> System.out.println(b.getName()+ "," + b.getPrice()));

  20. }

  21. private static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {

  22. Map<Object,Boolean> seen = new ConcurrentHashMap<>();

  23. return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;

  24. }

  25. }

Output 

 

 
  1. Core Java,200

  2. Learning Freemarker,150

  3. Spring MVC,200

  4. Hibernate,300

from : https://www.concretepage.com/java/jdk-8/java-8-distinct-example


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)