Java 8 stream in cortocircuito

Question

Leggendo un po 'su Java 8, ho ottenuto il post del blog this spiegando un po' di flussi e riduzione di essi e quando sarebbe stato possibile cortocircuitare la riduzione. In basso si legge:

Nota nel caso di findFirst o findAny abbiamo solo bisogno il primo valore che corrisponde al predicato (anche se findAny non è garantito per restituire la prima). Tuttavia, se lo stream non ha ordini, ci aspetteremmo che findFirst si comporti come findAny. Le operazioni allMatch, noneMatch e anyMatch non possono cortocircuitare il flusso poiché potrebbe richiedere la valutazione di tutti i valori per determinare se l'operatore è true o false. Quindi un flusso infinito che utilizza questi non può terminare.

ottengo che findFirst o findAny può cortocircuitare la riduzione, perché non appena AF a trovare un elemento, non hai bisogno di elaborare ulteriormente qualsiasi.

Ma perché questo non sarebbe possibile per allMatch, noneMatch e anyMatch? Per allMatch, se ne trovi uno che non corrisponde al predicato, puoi interrompere l'elaborazione. Lo stesso per nessuno. E anyMatch in particolare non ha senso per me, in quanto è praticamente uguale a findAny (ad eccezione di ciò che viene restituito)?

Dire che questi tre non possono cortocircuitare, perché potrebbe richiedere la valutazione di tutti i valori, si potrebbe anche dire per findFirst/Any.

C'è qualche differenza fondamentale che mi manca? Non capisco davvero cosa sta succedendo?

Answer 1

C'è una sottile differenza, perché la famiglia anyMatch utilizza un predicato, mentre la famiglia findAny non lo fa. Tecnicamente lo findAny() si presenta come anyMatch(x -> true) e anyMatch(pred) come filter(pred).findAny(). Quindi qui abbiamo un altro problema. Considerare abbiamo un semplice flusso infinito:

Stream<Integer> s = Stream.generate(() -> 1); 

Allora è vero che l'applicazione findAny() a tale flusso sarà sempre il corto circuito e la finitura durante l'applicazione anyMatch(pred) dipende dal predicato. Tuttavia filtriamo il nostro flusso infinito:

Stream<Integer> s = Stream.generate(() -> 1).filter(x -> x < 0); 

Il flusso risultante è infinito? Questa è una domanda complicata. In realtà non contiene elementi, ma per determinarlo (ad esempio, usando .iterator().hasNext()) dobbiamo controllare il numero infinito di elementi di flusso sottostanti, quindi questa operazione non finirà mai. Chiamerei anche questo flusso infinito. Tuttavia utilizzando tale flusso sia anyMatch e findAny non potrà mai finire:

Stream.generate(() -> 1).filter(x -> x < 0).anyMatch(x -> true); 
Stream.generate(() -> 1).filter(x -> x < 0).findAny(); 

Quindi findAny() non è garantito per finire o, dipende da precedenti operazioni di flusso intermedio.

Per concludere, ritengo che il post di blog sia molto fuorviante. A mio parere, il comportamento del flusso infinito è meglio spiegato in JavaDoc ufficiale.

Answer 2

Quando javadoc dice "potrebbe non cortocircuitare", si limita a sottolineare che non si tratta di un'operazione di cortocircuito e, a seconda dei valori, è possibile elaborare l'intero flusso.

findFirst e findAny d'altra parte, sono garantiti a corto circuito poiché non hanno mai bisogno di elaborare il resto del flusso una volta che sono soddisfatti.

Answer 3

anyMatch, noneMatch e allMatch restituiscono valori booleani, quindi potrebbero dover controllare tutti per provare la logica.

findFirst e find A tutti interessa trovare il primo possibile e restituirlo.

Modifica: Per un determinato set di dati è garantito che i metodi di corrispondenza restituiscono sempre lo stesso valore, tuttavia i metodi di ricerca non sono perché l'ordine può variare e influire sul valore restituito.

Il cortocircuito descritto sta parlando dei metodi Find privi di coerenza per un determinato set di dati.

Answer 4

risposta Aggiornato

direi che il post sul blog è sbagliato quando si dice "FindFirst o findAny abbiamo solo bisogno il primo valore che corrisponde al predicato".

Nel javadoc per allMatch(Predicate), anyMatch(Predicate), noneMatch(Predicate), findAny() e findFirst():

Questa è un'operazione terminale cortocircuito.

Si noti tuttavia che findFirst e findAny non hai Predicate. Quindi possono entrambi tornare immediatamente dopo aver visto il primo/qualsiasi valore. Gli altri 3 sono condizionali e possono essere interrotti per sempre se la condizione non si attiva mai.

Answer 5

Da Documentation Stream Oracle: https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html#StreamOps

Un'operazione terminale è corto circuito se, quando sono presentati con ingresso infinita, può terminare in tempo finito. Avere un'operazione di cortocircuito nella pipeline è una condizione necessaria, ma non sufficiente, per l'elaborazione di un flusso infinito per terminare normalmente in un tempo finito.

Tutti e cinque funzioni hanno la linea:

Questa è un'operazione terminale cortocircuito.

Nella descrizione della funzione.