Class AbstractParallelIterable<T, B extends Batch<T>>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>

All Implemented Interfaces:

ParallelIterable<T>

Direct Known Subclasses:

AbstractParallelIterableImpl, AbstractParallelListIterable, AbstractParallelSortedSetIterable, AbstractParallelUnsortedBag, AbstractParallelUnsortedSetIterable

public abstract class AbstractParallelIterable<T, B extends Batch<T>>
extends Object
implements ParallelIterable<T>

Constructor Summary

Constructors

Constructor	Description
AbstractParallelIterable()

Method Summary

Modifier and Type	Method	Description
<K,V> MapIterable<K,V>	aggregateBy(Function<? super T, ? extends K> groupBy, Function0<? extends V> zeroValueFactory, Function2<? super V, ? super T, ? extends V> nonMutatingAggregator)
<K,V> MapIterable<K,V>	aggregateInPlaceBy(Function<? super T, ? extends K> groupBy, Function0<? extends V> zeroValueFactory, Procedure2<? super V, ? super T> mutatingAggregator)
protected static <T> boolean	allSatisfy(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Predicate<? super T> predicate)
<P> boolean	allSatisfyWith(Predicate2<? super T, ? super P> predicate, P parameter)
protected static <T> boolean	anySatisfy(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Predicate<? super T> predicate)
<P> boolean	anySatisfyWith(Predicate2<? super T, ? super P> predicate, P parameter)
void	appendString(Appendable appendable, String start, String separator, String end)
protected <S,V> void	collectCombine(Function<Batch<T>,V> function, Procedure2<S,V> combineProcedure, S state)
private <S,V> void	collectCombineOrdered(Function<Batch<T>,V> function, Procedure2<S,V> combineProcedure, S state)
private <S,V> void	collectCombineUnordered(Function<Batch<T>,V> function, Procedure2<S,V> combineProcedure, S state)
private T	collectReduce(Function<Batch<T>,T> map, Function2<T,T,T> function2)
private T	collectReduceOrdered(Function<Batch<T>,T> map, Function2<T,T,T> function2)
private T	collectReduceUnordered(Function<Batch<T>,T> map, Function2<T,T,T> function2)
int	count(Predicate<? super T> predicate)
<P> int	countWith(Predicate2<? super T, ? super P> predicate, P parameter)
protected static <T> T	detect(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Predicate<? super T> predicate)
T	detectIfNone(Predicate<? super T> predicate, Function0<? extends T> function)
<P> T	detectWith(Predicate2<? super T, ? super P> predicate, P parameter)
<P> T	detectWithIfNone(Predicate2<? super T, ? super P> predicate, P parameter, Function0<? extends T> function)
protected static <T> void	forEach(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Procedure<? super T> procedure)
<P> void	forEachWith(Procedure2<? super T, ? super P> procedure, P parameter)
abstract int	getBatchSize()
abstract ExecutorService	getExecutorService()
<V> MapIterable<V,T>	groupByUniqueKey(Function<? super T, ? extends V> function)
protected abstract boolean	isOrdered()
T	max()
T	max(Comparator<? super T> comparator)
<V extends Comparable<? super V>> T	maxBy(Function<? super T, ? extends V> function)
T	min()
T	min(Comparator<? super T> comparator)
<V extends Comparable<? super V>> T	minBy(Function<? super T, ? extends V> function)
boolean	noneSatisfy(Predicate<? super T> predicate)
<P> boolean	noneSatisfyWith(Predicate2<? super T, ? super P> predicate, P parameter)
abstract LazyIterable<B>	split()
double	sumOfDouble(DoubleFunction<? super T> function)	Returns the final double result of evaluating function for each element of the iterable in parallel and adding the results together.
private double	sumOfDoubleOrdered(Function<Batch<T>, DoubleSumResultHolder> map)
double	sumOfFloat(FloatFunction<? super T> function)	Returns the final double result of evaluating function for each element of the iterable in parallel and adding the results together.
long	sumOfInt(IntFunction<? super T> function)	Returns the final long result of evaluating function for each element of the iterable in parallel and adding the results together.
long	sumOfLong(LongFunction<? super T> function)	Returns the final long result of evaluating function for each element of the iterable in parallel and adding the results together.
private long	sumOfLongOrdered(LongFunction<Batch<T>> map)
<E> E[]	toArray(E[] array)
MutableBag<T>	toBag()
MutableList<T>	toList()
<NK,NV> MutableMap<NK,NV>	toMap(Function<? super T, ? extends NK> keyFunction, Function<? super T, ? extends NV> valueFunction)
MutableSet<T>	toSet()
MutableSortedBag<T>	toSortedBag()
MutableSortedBag<T>	toSortedBag(Comparator<? super T> comparator)
<V extends Comparable<? super V>> MutableSortedBag<T>	toSortedBagBy(Function<? super T, ? extends V> function)
MutableList<T>	toSortedList(Comparator<? super T> comparator)
<V extends Comparable<? super V>> MutableList<T>	toSortedListBy(Function<? super T, ? extends V> function)
<NK,NV> MutableSortedMap<NK,NV>	toSortedMap(Comparator<? super NK> comparator, Function<? super T, ? extends NK> keyFunction, Function<? super T, ? extends NV> valueFunction)
<NK,NV> MutableSortedMap<NK,NV>	toSortedMap(Function<? super T, ? extends NK> keyFunction, Function<? super T, ? extends NV> valueFunction)
MutableSortedSet<T>	toSortedSet()
MutableSortedSet<T>	toSortedSet(Comparator<? super T> comparator)
<V extends Comparable<? super V>> MutableSortedSet<T>	toSortedSetBy(Function<? super T, ? extends V> function)
String	toString()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ParallelIterable

allSatisfy, anySatisfy, appendString, appendString, asUnique, collect, collectIf, collectWith, detect, flatCollect, forEach, groupBy, groupByEach, makeString, makeString, makeString, makeString, reject, rejectWith, select, selectInstancesOf, selectWith, toArray, toSortedList

Constructor Details

AbstractParallelIterable

public AbstractParallelIterable()

Method Details

forEach

protected static <T> void forEach(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable,
 Procedure<? super T> procedure)

anySatisfy

protected static <T> boolean anySatisfy(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable,
 Predicate<? super T> predicate)

allSatisfy

protected static <T> boolean allSatisfy(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable,
 Predicate<? super T> predicate)

detect

protected static <T> T detect(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable,
 Predicate<? super T> predicate)

getExecutorService

public abstract ExecutorService getExecutorService()

getBatchSize

public abstract int getBatchSize()

split

public abstract LazyIterable<B> split()

isOrdered

protected abstract boolean isOrdered()

collectCombine

protected <S,V> void collectCombine(Function<Batch<T>,V> function,
 Procedure2<S,V> combineProcedure,
 S state)

collectCombineOrdered

private <S,V> void collectCombineOrdered(Function<Batch<T>,V> function,
 Procedure2<S,V> combineProcedure,
 S state)

collectCombineUnordered

private <S,V> void collectCombineUnordered(Function<Batch<T>,V> function,
 Procedure2<S,V> combineProcedure,
 S state)

collectReduce

private T collectReduce(Function<Batch<T>,T> map,
 Function2<T,T,T> function2)

collectReduceOrdered

private T collectReduceOrdered(Function<Batch<T>,T> map,
 Function2<T,T,T> function2)

collectReduceUnordered

private T collectReduceUnordered(Function<Batch<T>,T> map,
 Function2<T,T,T> function2)

toString

public String toString()

Overrides:

toString in class Object

appendString

public void appendString(Appendable appendable,
 String start,
 String separator,
 String end)

Specified by:

appendString in interface ParallelIterable<T>

forEachWith

public <P> void forEachWith(Procedure2<? super T, ? super P> procedure,
 P parameter)

Specified by:

forEachWith in interface ParallelIterable<T>

anySatisfyWith

public <P> boolean anySatisfyWith(Predicate2<? super T, ? super P> predicate,
 P parameter)

Specified by:

anySatisfyWith in interface ParallelIterable<T>

allSatisfyWith

public <P> boolean allSatisfyWith(Predicate2<? super T, ? super P> predicate,
 P parameter)

Specified by:

allSatisfyWith in interface ParallelIterable<T>

noneSatisfy

public boolean noneSatisfy(Predicate<? super T> predicate)

Specified by:

noneSatisfy in interface ParallelIterable<T>

noneSatisfyWith

public <P> boolean noneSatisfyWith(Predicate2<? super T, ? super P> predicate,
 P parameter)

Specified by:

noneSatisfyWith in interface ParallelIterable<T>

detectWith

public <P> T detectWith(Predicate2<? super T, ? super P> predicate,
 P parameter)

Specified by:

detectWith in interface ParallelIterable<T>

detectIfNone

public T detectIfNone(Predicate<? super T> predicate,
 Function0<? extends T> function)

Specified by:

detectIfNone in interface ParallelIterable<T>

detectWithIfNone

public <P> T detectWithIfNone(Predicate2<? super T, ? super P> predicate,
 P parameter,
 Function0<? extends T> function)

Specified by:

detectWithIfNone in interface ParallelIterable<T>

toArray

public <E> E[] toArray(E[] array)

Specified by:

toArray in interface ParallelIterable<T>

toList

public MutableList<T> toList()

Specified by:

toList in interface ParallelIterable<T>

toSortedList

public MutableList<T> toSortedList(Comparator<? super T> comparator)

Specified by:

toSortedList in interface ParallelIterable<T>

toSortedListBy

public <V extends Comparable<? super V>>
MutableList<T> toSortedListBy(Function<? super T, ? extends V> function)

Specified by:

toSortedListBy in interface ParallelIterable<T>

toSet

public MutableSet<T> toSet()

Specified by:

toSet in interface ParallelIterable<T>

toSortedSet

public MutableSortedSet<T> toSortedSet()

Specified by:

toSortedSet in interface ParallelIterable<T>

toSortedSetBy

public <V extends Comparable<? super V>>
MutableSortedSet<T> toSortedSetBy(Function<? super T, ? extends V> function)

Specified by:

toSortedSetBy in interface ParallelIterable<T>

toBag

public MutableBag<T> toBag()

Specified by:

toBag in interface ParallelIterable<T>

toSortedBag

public MutableSortedBag<T> toSortedBag()

Specified by:

toSortedBag in interface ParallelIterable<T>

toSortedBag

public MutableSortedBag<T> toSortedBag(Comparator<? super T> comparator)

Specified by:

toSortedBag in interface ParallelIterable<T>

toSortedBagBy

public <V extends Comparable<? super V>>
MutableSortedBag<T> toSortedBagBy(Function<? super T, ? extends V> function)

Specified by:

toSortedBagBy in interface ParallelIterable<T>

toSortedSet

public MutableSortedSet<T> toSortedSet(Comparator<? super T> comparator)

Specified by:

toSortedSet in interface ParallelIterable<T>

toMap

public <NK,NV> MutableMap<NK,NV> toMap(Function<? super T, ? extends NK> keyFunction,
 Function<? super T, ? extends NV> valueFunction)

Specified by:

toMap in interface ParallelIterable<T>

toSortedMap

public <NK,NV> MutableSortedMap<NK,NV> toSortedMap(Function<? super T, ? extends NK> keyFunction,
 Function<? super T, ? extends NV> valueFunction)

Specified by:

toSortedMap in interface ParallelIterable<T>

toSortedMap

public <NK,NV> MutableSortedMap<NK,NV> toSortedMap(Comparator<? super NK> comparator,
 Function<? super T, ? extends NK> keyFunction,
 Function<? super T, ? extends NV> valueFunction)

Specified by:

toSortedMap in interface ParallelIterable<T>

aggregateBy

public <K,V> MapIterable<K,V> aggregateBy(Function<? super T, ? extends K> groupBy,
 Function0<? extends V> zeroValueFactory,
 Function2<? super V, ? super T, ? extends V> nonMutatingAggregator)

Specified by:

aggregateBy in interface ParallelIterable<T>

aggregateInPlaceBy

public <K,V> MapIterable<K,V> aggregateInPlaceBy(Function<? super T, ? extends K> groupBy,
 Function0<? extends V> zeroValueFactory,
 Procedure2<? super V, ? super T> mutatingAggregator)

Specified by:

aggregateInPlaceBy in interface ParallelIterable<T>

count

public int count(Predicate<? super T> predicate)

Specified by:

count in interface ParallelIterable<T>

countWith

public <P> int countWith(Predicate2<? super T, ? super P> predicate,
 P parameter)

Specified by:

countWith in interface ParallelIterable<T>

min

public T min(Comparator<? super T> comparator)

Specified by:

min in interface ParallelIterable<T>

max

public T max(Comparator<? super T> comparator)

Specified by:

max in interface ParallelIterable<T>

min

public T min()

Specified by:

min in interface ParallelIterable<T>

max

public T max()

Specified by:

max in interface ParallelIterable<T>

minBy

public <V extends Comparable<? super V>> T minBy(Function<? super T, ? extends V> function)

Specified by:

minBy in interface ParallelIterable<T>

maxBy

public <V extends Comparable<? super V>> T maxBy(Function<? super T, ? extends V> function)

Specified by:

maxBy in interface ParallelIterable<T>

sumOfInt

public long sumOfInt(IntFunction<? super T> function)

Description copied from interface: ParallelIterable

Returns the final long result of evaluating function for each element of the iterable in parallel and adding the results together.

Specified by:

sumOfInt in interface ParallelIterable<T>

sumOfFloat

public double sumOfFloat(FloatFunction<? super T> function)

Description copied from interface: ParallelIterable

Returns the final double result of evaluating function for each element of the iterable in parallel and adding the results together. It uses Kahan summation algorithm to reduce numerical error.

Specified by:

sumOfFloat in interface ParallelIterable<T>

sumOfLong

public long sumOfLong(LongFunction<? super T> function)

Description copied from interface: ParallelIterable

Returns the final long result of evaluating function for each element of the iterable in parallel and adding the results together.

Specified by:

sumOfLong in interface ParallelIterable<T>

sumOfDouble

public double sumOfDouble(DoubleFunction<? super T> function)

Description copied from interface: ParallelIterable

Returns the final double result of evaluating function for each element of the iterable in parallel and adding the results together. It uses Kahan summation algorithm to reduce numerical error.

Specified by:

sumOfDouble in interface ParallelIterable<T>

sumOfLongOrdered

private long sumOfLongOrdered(LongFunction<Batch<T>> map)

sumOfDoubleOrdered

private double sumOfDoubleOrdered(Function<Batch<T>, DoubleSumResultHolder> map)

groupByUniqueKey

public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T, ? extends V> function)

Specified by:

groupByUniqueKey in interface ParallelIterable<T>