编程语言
首页 > 编程语言> > Java 8 Stream.distinct() 列表去重示例

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

作者:互联网

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

标签:Java,示例,distinct,list,Book,new,java,public
来源: https://www.cnblogs.com/ExMan/p/16386491.html