0Pricing
Java Academy · Lektion

Spliterator: Aufteilen für Parallelität

Implementieren Sie einen eigenen Spliterator, um Domänendaten als aufteilbare Stream-Quelle bereitzustellen.

Spliterator: Aufteilen für Parallelität ist eine kostenlose Java Academy-Lektion auf CoddyKit. Dies ist Lektion 3 von 4. Du kannst die komplette Lektion unten kostenlos lesen – dann übst du sie direkt im Browser mit einem integrierten Code-Editor und einem KI-Tutor rund um die Uhr. Sie ist Teil des Java Academy-Lernpfads, und dein Fortschritt wird über Web und CoddyKit-App synchronisiert. Der Java Academy-Kurs umfasst insgesamt 4 Lektionen.

Was ist ein Spliterator?

Ein Spliterator (teilbarer Iterator) ist der grundlegende Mechanismus hinter Streams. Er durchläuft Elemente und kann sich für die parallele Verarbeitung in zwei Teile aufteilen.

Wichtige Spliterator-Methoden

Es gibt vier zentrale Methoden: tryAdvance (ein Element verarbeiten), forEachRemaining (alle verbleibenden Elemente verarbeiten), trySplit (in zwei Teile aufteilen) und estimateSize (Elementanzahl schätzen).

Spliterator<Integer> sp = List.of(1,2,3,4,5,6).spliterator();
Spliterator<Integer> half = sp.trySplit(); // splits off first ~half
half.forEachRemaining(System.out::println); // 1 2 3
sp.forEachRemaining(System.out::println);   // 4 5 6

Eigenschaften von Spliteratoren

Spliteratoren geben ihre Eigenschaften mithilfe von Bit-Flags an: SIZED, ORDERED, DISTINCT, SORTED, NONNULL, IMMUTABLE, CONCURRENT, SUBSIZED.

Spliterator<String> sp = List.of("a","b","c").spliterator();
System.out.println(Integer.toBinaryString(sp.characteristics()));
// Characteristics include ORDERED, SIZED, SUBSIZED

So funktioniert trySplit

trySplit() gibt einen neuen Spliterator zurück, der ungefähr die Hälfte der verbleibenden Elemente umfasst. Der ursprüngliche Spliterator umfasst die andere Hälfte. Geben Sie null zurück, wenn eine Aufteilung nicht möglich ist.

// ArrayList Spliterator splits efficiently at midpoint:
// [0,1,2,3,4,5] -> [0,1,2] (new) + [3,4,5] (original)

Einen eigenen Spliterator erstellen

Implementieren Sie Spliterator<T>, um eine eigene Datenstruktur als Stream-Quelle bereitzustellen. Definieren Sie trySplit, um die Parallelisierung zu ermöglichen.

public class RangeSpliterator implements Spliterator<Integer> {
    private int start, end;
    public RangeSpliterator(int start, int end) { this.start=start; this.end=end; }
    public boolean tryAdvance(Consumer<? super Integer> action) {
        if (start >= end) return false;
        action.accept(start++); return true;
    }
    public Spliterator<Integer> trySplit() {
        int mid = (start + end) / 2;
        if (mid <= start) return null;
        RangeSpliterator prefix = new RangeSpliterator(start, mid);
        this.start = mid; return prefix;
    }
    public long estimateSize() { return end - start; }
    public int characteristics() { return ORDERED | SIZED | SUBSIZED | IMMUTABLE; }
}

Einen Stream aus einem Spliterator erstellen

Verwenden Sie StreamSupport.stream(spliterator, parallel), um aus einem beliebigen Spliterator einen Stream zu erstellen – die Verbindung zwischen eigenen Datenquellen und der Stream API.

Spliterator<Integer> sp = new RangeSpliterator(0, 1_000_000);
Stream<Integer> stream = StreamSupport.stream(sp, true); // true = parallel
long count = stream.filter(n -> n % 2 == 0).count();
System.out.println(count); // 500000

Spliterator für einen Binärbaum

Eigene Spliteratoren ermöglichen die Parallelisierung von Strukturen wie Bäumen, die keine Listen sind. trySplit gibt den Spliterator des linken Teilbaums zurück und behält den rechten Teilbaum.

Effizienz der Parallelisierung und Qualität der Aufteilung

Parallele Streams teilen sich rekursiv auf, bis die Teilmengen klein genug für einen einzelnen Thread sind. Eine gute Aufteilung erfordert eine genaue Schätzung durch estimateSize und ungefähr gleich große Teilmengen.

forEachRemaining für die Stapelverarbeitung

Wenn keine Aufteilung erforderlich ist, überschreiben Sie forEachRemaining, um eine Stapelverarbeitung zu ermöglichen. Dadurch vermeiden Sie den Overhead pro Element, der bei einer Schleife mit tryAdvance entsteht.

@Override
public void forEachRemaining(Consumer<? super Integer> action) {
    for (int i = start; i < end; i++) action.accept(i);
    start = end; // mark as exhausted
}

Spliterator und Iterator im Vergleich

Iterator: nur sequenziell, kein Hinweis auf die Größe, keine Aufteilung. Spliterator: für Parallelisierung geeignet, stellt Eigenschaften und eine Größenschätzung bereit und wurde für die Stream API entwickelt.

Kurze Überprüfung

Was gibt trySplit() zurück, wenn eine Aufteilung nicht möglich ist?

Zusammenfassung

Spliterator ist die Grundlage paralleler Streams. Implementieren Sie tryAdvance, trySplit, estimateSize und characteristics, um eigene Datenstrukturen als Streams bereitzustellen. Verwenden Sie StreamSupport.stream(sp, true), um die parallele Verarbeitung zu aktivieren.

Häufig gestellte Fragen

Ist die Lektion „Spliterator: Aufteilen für Parallelität“ kostenlos?

Ja — der vollständige Text von „Spliterator: Aufteilen für Parallelität“ ist hier im Web kostenlos zu lesen. Um sie interaktiv zu üben (integrierter Code-Editor und 24/7 KI-Tutor) und den Rest des Java Academy-Kurses freizuschalten, upgrade auf CoddyKit PRO. Der Java Academy-Kurs umfasst insgesamt 4 Lektionen.

Was lerne ich in „Spliterator: Aufteilen für Parallelität“?

Implementieren Sie einen eigenen Spliterator, um Domänendaten als aufteilbare Stream-Quelle bereitzustellen. Du übst Java Academy mit praktischem Code, den du direkt im Browser ausführst, und ein 24/7 KI-Tutor beantwortet deine Fragen während du die Lektion bearbeitest.

Brauche ich Erfahrung, um Java Academy zu starten?

Keine Vorkenntnisse erforderlich. Java Academy auf CoddyKit ist für Anfänger bis fortgeschrittene Lernende strukturiert, sodass du hier starten oder von Anfang an beginnen und in deinem eigenen Tempo voranschreiten kannst. Dies ist Lektion 3 von 4.

Wie lange dauert die Lektion „Spliterator: Aufteilen für Parallelität“?

Die meisten CoddyKit-Lektionen dauern etwa 5–10 Minuten. Jede ist kompakt und interaktiv, sodass du stetig Fortschritte machst und genau dort weitermachst, wo du aufgehört hast – im Web und in der App.

Kann ich in dieser Java Academy-Lektion Code schreiben und ausführen?

Ja. Jede Java Academy-Lektion enthält einen integrierten Code-Editor, sodass du echten Code direkt in deinem Browser schreibst und ausführst und sofort KI-Feedback erhältst — ohne lokale Einrichtung erforderlich.

Alle Lektionen in diesem Kurs

  1. flatMap für verschachtelte Collections
  2. Parallele Streams: Leistung und Fallstricke
  3. Spliterator: Aufteilen für Parallelität
  4. Unendliche Streams mit iterate und generate
← Zurück zu Java Academy