Java 8 Stream distinct 不起作用

Question

这就是我正在做的：

List scores = Stream.concat(oldEntries.stream(), newEntries.stream())
                    .sorted()
                    .distinct()
                    .limit(maxSize)
                    .collect(Collectors.toList());

我期待一个没有任何重复的排序列表，但有时列表中有重复。

我已经重写了 hashCode 和 equals 方法，我还观察到这些方法每次都返回正确的值。任何人都可以看到我的流有什么问题吗？

这是我的 equals() 和 hashCode() 它们是由 IDEA 自动生成的：

..
private int userId;
private int levelId;
private int score;

@Override
public boolean equals(Object o) {

    if (this == o) return true;
    if (o == null || getClass() != o.getClass()) return false;

    Score score = (Score) o;

    if (userId != score.userId) return false;
    return levelId == score.levelId;

}

@Override
public int hashCode() {
    int result = userId;
    result = 31 * result + levelId;
    return result;
}

public int compareTo(Score other) {

    if (other == null) {
        return 1;
    } else {
        return Integer.compare(other.score, this.score);
    }
}

 ..

Answer 1

这是一个错误。

Stream.distinct() 的文档简单地说：

返回由不同元素组成的流（根据 此流的Object.equals(Object))。

对于有序流，不同元素的选择是稳定的（对于 重复元素，该元素首先出现在遭遇战中 顺序被保留。）对于无序流，没有稳定性保证 制作完成。

对于有序流，没有要求相等的对象应该紧挨着（连续地）出现。然而，实施似乎假设他们这样做。文档的意思是应该保留第一次出现的 user 2, level 3 而丢弃第二次出现的。

根据 Java 错误数据库，该错误一直存在到 Java 13 并且仍未解决。

链接

• Documentation of Stream.distinct()
• JDK-8223933 Stream.distinct() sometimes allows duplicates when the stream is sorted 在 JDK 错误系统中。

Answer 2

您的流首先根据compareTo 排序，即使用score。

然后使用equals() 对其进行“区分”，即使用userId 和levelId。根据javadoc：

对于有序流，不同元素的选择是稳定的（对于 重复元素，该元素首先出现在遭遇战中 顺序被保留。）对于无序流，没有稳定性保证 制作完成。

例子：

score 1, user 2, level 3
score 3, user 2, level 3
score 1, user 3, level 1

排序后...

score 1, user 2, level 3
score 1, user 3, level 1
score 3, user 2, level 3

Distinct 现在什么都不做，因为根据用户/级别，元素不相等。这可能会导致“重复”元素，因为您是基于一个事物对流进行排序，但通过完全不同的事物来确定相等性。