Package org.eclipse.collections.impl.lazy.parallel

Class AbstractMultiReaderParallelIterable<T,PI extends ParallelIterable<T>>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractMultiReaderParallelIterable<T,PI>

All Implemented Interfaces:

ParallelIterable<T>

Direct Known Subclasses:

MultiReaderParallelIterable, MultiReaderParallelListIterable, MultiReaderParallelUnsortedSetIterable

public abstract class AbstractMultiReaderParallelIterable<T,PI extends ParallelIterable<T>>
extends Object
implements ParallelIterable<T>

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)
boolean	allSatisfy(Predicate<? super T> predicate)
<P> boolean	allSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
boolean	anySatisfy(Predicate<? super T> predicate)
<P> boolean	anySatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
void	appendString(Appendable appendable)
void	appendString(Appendable appendable, String separator)
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	detect(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)
void	forEach(Procedure<? super T> procedure)
<P> void	forEachWith(Procedure2<? super T,? super P> procedure, P parameter)
<V> MapIterable<V,T>	groupByUniqueKey(Function<? super T,? extends V> function)
String	makeString()
String	makeString(String separator)
String	makeString(String start, String separator, String end)
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)
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.
Object[]	toArray()
<T1> T1[]	toArray(T1[] target)
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()
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

asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, reject, rejectWith, select, selectInstancesOf, selectWith

Method Details

forEach

public void forEach(Procedure<? super T> procedure)

Specified by:

forEach in interface ParallelIterable<T>

forEachWith

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

Specified by:

forEachWith in interface ParallelIterable<T>

detect

public T detect(Predicate<? super T> predicate)

Specified by:

detect 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>

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>

anySatisfy

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

Specified by:

anySatisfy in interface ParallelIterable<T>

anySatisfyWith

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

Specified by:

anySatisfyWith in interface ParallelIterable<T>

allSatisfy

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

Specified by:

allSatisfy 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>

toList

public MutableList<T> toList()

Specified by:

toList in interface ParallelIterable<T>

toSortedList

public MutableList<T> toSortedList()

Specified by:

toSortedList 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>

toSortedSet

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

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>

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>

toArray

public Object[] toArray()

Specified by:

toArray in interface ParallelIterable<T>

toArray

public <T1> T1[] toArray(T1[] target)

Specified by:

toArray 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>

makeString

public String makeString()

Specified by:

makeString in interface ParallelIterable<T>

makeString

public String makeString(String separator)

Specified by:

makeString in interface ParallelIterable<T>

makeString

public String makeString(String start,
 String separator,
 String end)

Specified by:

makeString in interface ParallelIterable<T>

appendString

public void appendString(Appendable appendable)

Specified by:

appendString in interface ParallelIterable<T>

appendString

public void appendString(Appendable appendable,
 String separator)

Specified by:

appendString in interface ParallelIterable<T>

appendString

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

Specified by:

appendString in interface ParallelIterable<T>

groupByUniqueKey

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

Specified by:

groupByUniqueKey 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>

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>

toString

public String toString()

Overrides:

toString in class Object