Java 8 Stream - .max() con i duplicati

Question

Così ho una collezione di oggetti che hanno una variabile passo che può essere 1 - 4.

public class MyClass { 
    private Long step; 

    //other variables, getters, setters, etc. 
} 

Collection<MyClass> myOjbects = /*get collection*/;

Poi vorrei ottenere un'istanza MyClass dalla collezione che ha il valore massimo passaggio, quindi fare:

final Optional<MyClass> objectWithMaxStep = 
    myObjects.stream().max(Comparator.comparing(MyClass::getStep)); 

Tuttavia, vi sono situazioni in cui ci saranno più MyClass ins tance nella raccolta che hanno un passo uguale a 4.

Quindi, la mia domanda è, come viene determinata quale istanza viene restituita nello Optional o genera un'eccezione quando più oggetti nel flusso hanno il valore massimo che viene confrontato?

La documentazione Java 8 per la funzione max() non specifica cosa si verificherà in questa situazione.

Answer 1

max è implementato riducendo la collezione con maxBy:

public static <T> BinaryOperator<T> maxBy(Comparator<? super T> comparator) { 
     Objects.requireNonNull(comparator); 
     return (a, b) -> comparator.compare(a, b) >= 0 ? a : b; 
    } 

Qui comparator.compare(a, b) >= 0 ? a : b si può vedere che quando 2 elementi sono uguali, vale a dire compare restituisce 0, quindi il primo elemento viene restituito. Pertanto nel tuo caso verrà restituito prima in una collezione MyClass oggetto con il massimo step.

UPDATE: Come utente the8472 menzionato correttamente nei commenti, non si dovrebbe fare affidamento su di attuazione che non è esplicitamente specificato da javadocs. Ma puoi scrivere un test unitario sul metodo max per sapere se la logica è cambiata nella libreria java standard.

Answer 2

Poiché l'ordine non è specificato dalla documentazione, l'ordine può essere diverso nelle versioni future della JVM o in diverse implementazioni della JVM.

Se si cura quale viene restituito, il mio consiglio è di scrivere la propria operazione di riduzione o il Collezionista di comportarsi come si desidera. In questo modo le future implementazioni non possono cambiarlo e puoi dire esplicitamente cosa accadrà.