org.eclipse.collections.impl.lazy.parallel

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 and Description
AbstractParallelIterable()

Method Summary

Modifier and Type	Method and 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)
<P> boolean	allSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
<P> boolean	anySatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
void	appendString(Appendable appendable, String start, String separator, String end)
int	count(Predicate<? super T> predicate)
<P> int	countWith(Predicate2<? super T,? super P> predicate, P parameter)
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)
<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)
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.
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.
<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 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.eclipse.collections.api.ParallelIterable

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

Constructor Detail

AbstractParallelIterable

public AbstractParallelIterable()

Method Detail

getExecutorService

public abstract ExecutorService getExecutorService()

getBatchSize

public abstract int getBatchSize()

split

public abstract LazyIterable<B> split()

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>

groupByUniqueKey

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

Specified by:

groupByUniqueKey in interface ParallelIterable<T>