Java 8 Anwenden von Stromfilter auf der Grundlage einer Bedingung

Question

In Java 8, ist es eine Möglichkeit, den Filter auf einem Strom auf der Grundlage einer Bedingung anzuwenden,

Beispiel

ich diesen Strom haben

if (isAccessDisplayEnabled) { 
    src = (List <Source>) sourceMeta.getAllSources.parallelStream() 
     .filter(k - > isAccessDisplayEnabled((Source) k)) 
     .filter(k - > containsAll((Source) k, substrings, searchString)) 
     .collect(Collectors.toList()); 
} else { 
    src = (List <Source>) sourceMeta.getAllSources.parallelStream() 
     .filter(k - > containsAll((Source) k, substrings, searchString)) 
     .collect(Collectors.toList()); 
} 

ich füge den Filter

.filter (k -> isAccessDisplayEnabled ((Quelle) k)))

im Stream basierend auf der if-else-Bedingung. Gibt es eine Möglichkeit, dies zu vermeiden, wenn es sonst noch mehr Filter gibt, dann wird es schwer zu pflegen sein.

Bitte lassen Sie mich wissen

Answer 1

Eine Möglichkeit, es zu tun ist

Stream<Source> stream = sourceMeta.getAllSources.parallelStream().map(x -> (Source)x); 
if(isAccessDisplayEnabled) stream = stream.filter(s -> isAccessDisplayEnabled(s)); 
src = stream.filter(s - > containsAll(s, substrings, searchString)) 
      .collect(Collectors.toList()); 

andere

src = sourceMeta.getAllSources.parallelStream().map(x -> (Source)x) 
    .filter(isAccessDisplayEnabled? s - > isAccessDisplayEnabled(s): s -> true) 
    .filter(s - > containsAll(s, substrings, searchString)) 
    .collect(Collectors.toList()); 

In jedem Fall ist zu beachten, wie zu Beginn eine Art Guss Durchführung des pipline gesamten Strom vereinfacht.

Beide Lösungen vermeiden die Neubewertung von isAccessDisplayEnabled für jedes Stream-Element. Die zweite Lösung beruht jedoch auf der Fähigkeit der JVM, s -> true zu inlinern, wenn sich dieser Code als leistungskritisch erweist.

Answer 2

Ihr Zustand den gleichen Namen wie Ihre Methode hat. Ich werde dich zu übernehmen bedeutet für diejenigen, anders zu sein, also lassen Sie uns sagen, dass es das war:

if (someCondition) { 
    src = (List <Source>) sourceMeta.getAllSources.parallelStream() 
     .filter(k - > isAccessDisplayEnabled((Source) k)) 
     .filter(k - > containsAll((Source) k, substrings, searchString)) 
     .collect(Collectors.toList()); 
} else { 
    src = (List <Source>) sourceMeta.getAllSources.parallelStream() 
     .filter(k - > containsAll((Source) k, substrings, searchString)) 
     .collect(Collectors.toList()); 
} 

Wenn Sie die if/else entfernen möchten, können Sie stattdessen die Prüfung im ersten Filter durchführen:

src = (List <Source>) sourceMeta.getAllSources.parallelStream() 
    .filter(k - > !someCondition || isAccessDisplayEnabled((Source) k)) 
    .filter(k - > containsAll((Source) k, substrings, searchString)) 
    .collect(Collectors.toList()); 

im anderen Fall, nehmen Sie alles und die isAccessDisplayEnabled() -Methode entfernen, so ist die Bedingung wirksam „wenn someCondition falsch oder isAccessDisplayEnabled (k)“. Wenn someCondition false ausgibt, wird die Überprüfung von isAccessDisplayEnabled() übersprungen.