Spliterator Java 8 - пользовательская реализация

Question

Я изучаю эту функцию Java 8, и мне действительно трудно понять Spliterator интерфейса trySplit() реализация метода в случае пользовательских классов для параллельной обработки сгенерированного Stream,

Может кто-нибудь помочь мне с хорошим учебником с четким примером?

Answer 1

Идеальный метод trySplit эффективно (без обхода) делит его элементы ровно пополам, позволяя сбалансированные параллельные вычисления. Многие отклонения от этого идеала остаются очень эффективными; например, только приблизительно разделение приблизительно сбалансированного дерева, или для дерева, в котором конечные узлы могут содержать один или два элемента, не в состоянии дополнительно разделить эти узлы. Однако большие отклонения в балансе и / или чрезмерно неэффективные механизмы trySplit обычно приводят к плохой параллельной производительности.

и структура метода с комментариями

 public Spliterator<T> trySplit() {
   int lo = origin; // divide range in half
   int mid = ((lo + fence) >>> 1) & ~1; // force midpoint to be even
   if (lo < mid) { // split out left half
     origin = mid; // reset this Spliterator's origin
     return new TaggedArraySpliterator<>(array, lo, mid);
   }
   else       // too small to split
     return null;
 }

для дополнительной информации читайте на https://docs.oracle.com/javase/8/docs/api/java/util/Spliterator.html

Answer 2

Вот пример реализации Spliterator.

public class Payment {
    private String category;
    private double amount;

    public Payment(double amount, String category) {
        this.amount = amount;
        this.category = category;
    }

    public String getCategory() {
        return category;
    }

    public double getAmount() {
        return amount;
    }
}

Реализация TrySplit:

import java.util.List;
import java.util.Spliterator;
import java.util.function.Consumer;

public class PaymentBatchSpliterator implements Spliterator<Payment> {

    private List<Payment> paymentList;
    private int current;
    private int last;  // inclusive

    public PaymentBatchSpliterator(List<Payment> payments) {
        this.paymentList = payments;
        last = paymentList.size() - 1;
    }

    public PaymentBatchSpliterator(List<Payment> payments, int start, int last) {
        this.paymentList = payments;
        this.current = start;
        this.last = last;
    }

    @Override
    public boolean tryAdvance(Consumer<? super Payment> action) {
        if (current <= last) {
            action.accept(paymentList.get(current));
            current++;
            return true;
        }
        return false;
    }

    @Override
    public Spliterator<Payment> trySplit() {
        if ((last - current) < 100) {
            return null;
        }

        // first stab at finding a split position
        int splitPosition = current + (last - current) / 2;
        // if the categories are the same, we can't split here, as we are in the middle of a batch
        String categoryBeforeSplit = paymentList.get(splitPosition-1).getCategory();
        String categoryAfterSplit = paymentList.get(splitPosition).getCategory();

        // keep moving forward until we reach a split between categories
        while (categoryBeforeSplit.equals(categoryAfterSplit)) {
            splitPosition++;
            categoryBeforeSplit = categoryAfterSplit;
            categoryAfterSplit = paymentList.get(splitPosition).getCategory();
        }

        // safe to create a new spliterator
        PaymentBatchSpliterator secondHalf = new PaymentBatchSpliterator(paymentList,splitPosition,last);
        // reset our own last value
        last = splitPosition - 1;

        return secondHalf;
    }

    @Override
    public long estimateSize() {
        return last - current;
    }

    @Override
    public int characteristics() {
        return 0;
    }
}

Это пример из GitHub Reference