18.5    Einen Stream erzeugen 

Das Paket java.util.stream deklariert diverse Typen rund um Streams. Im Zentrum steht für Objektströme eine generisch deklarierte Schnittstelle Stream. Ein konkretes Exemplar wird immer von einer Datenquelle erzeugt. Unter anderem stehen folgende Stream-Erzeuger zur Verfügung:

Tabelle 18.1     Methoden, die Stream-Exemplare liefern

Die Methode Stream.empty() liefert wie erwartet einen Strom ohne Elemente.

Stream.of*(…)

Stream hat einige Fabrikmethoden für neue Ströme (etwa of(…)), alles andere sind Objektmethoden anderer Klassen, die Ströme liefern. Die of(…)-Methoden sind als statische Schnittstellenmethoden von Stream implementiert, und of(T… values) ist nur eine Fassade für Arrays.stream(values). Die Methode static <T> Stream<T> ofNullable(T t) liefert, wenn t == null ist, einen leeren Stream; und wenn t != null ist, liefert sie einen Stream mit genau dem Element t. Die Methode ist nützlich für Teilströme, die integriert werden.

Stream.of( -4, 1, -2, 3 )

      .map( Math::abs )

      .sorted()

      .forEach( System.out::println ); // 1 2 3 4

Stream.generate(…)

generate(…) produziert Elemente aus einem Supplier; der Stream ist unendlich.

class FibSupplier implements Supplier<BigInteger> {

  private final Queue<BigInteger> fibs =

      new LinkedList<>( Arrays.asList( BigInteger.ZERO, BigInteger.ONE ) );

  @Override public BigInteger get() {

    fibs.offer( fibs.remove().add( fibs.peek() ) );

    return fibs.peek();

  }

};

Stream.generate( new FibSupplier() )

      .limit( 1000 ).forEach( System.out::println );

Stream.iterate(…)

Die zwei statischen iterate(…)-Methoden generieren einen Stream aus einem Startwert und einer Funktion, die das nächste Element produziert. Bei iterate(T seed, UnaryOperator<T> f) ist der Strom unendlich, bei der zweiten (in Java 9 hinzugekommenen) Methode iterate(…, Predicate<? super T> hasNext, …) beendet ein erfülltes Prädikat den Strom und erinnert an eine klassische for-Schleife. Der Abbruch über ein Prädikat ist sehr flexibel, denn bei der ersten iterate(…)-Methode ist der Strom unendlich, und so folgt oftmals ein limit(…) oder takeWhile(…) zum Limitieren der Elemente.

UnaryOperator<String> shuffleOp = s -> {

  char[] chars = s.toCharArray();

  for ( int index = chars.length - 1; index > 0; index-- ) {

    int rndIndex = ThreadLocalRandom.current().nextInt( index + 1 );

    if ( index == rndIndex ) continue;

    char c = chars[ rndIndex ];

    chars[ rndIndex ] = chars[ index ];

    chars[ index ] = c;

  }

  return new String( chars );

};

String text = "Sie müssen nur den Nippel durch die Lasche ziehn";

Stream.iterate( text, shuffleOp ).limit( 10 ).forEach( System.out::println );

Predicate<BigInteger> isNotPrime = i -> ! i.isProbablePrime( 10 );

UnaryOperator<BigInteger> incBigInt = i -> i.add( BigInteger.ONE );

Stream.iterate( BigInteger.valueOf( 10_000_000 ), isNotPrime, incBigInt )

      .forEach( System.out::println );

 

18.5.1    Parallele oder sequenzielle Streams 

Ein Stream kann parallel oder sequenziell sein. Das heißt, es ist möglich, dass Threads gewisse Operationen nebenläufig durchführen, wie zum Beispiel die Suche nach einem Element. Stream liefert über isParallel() die Rückgabe true, wenn ein Stream Operationen nebenläufig durchführt.

Alle Collection-Datenstrukturen können mit der Methode parallelStream() einen potenziell nebenläufigen Stream liefern.

Tabelle 18.2     Parallele und nichtparallele Streams von jeder »Collection« erfragen

Jeder parallele Stream lässt sich mithilfe der Stream-Methode sequential() in einen sequenziellen Stream konvertieren. Parallele Streams nutzen intern das Fork-&-Join-Framework, doch sollte nicht automatisch jeder Stream parallel sein, da das nicht zwingend zu einem Performance-Vorteil führt. Wenn zum Beispiel keine Parallelisierung möglich ist, bringt es wenig, Threads einzusetzen.