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 java.lang.Object implements ParallelIterable<T>
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractMultiReaderParallelIterable(PI delegate, java.util.concurrent.locks.ReadWriteLock lock)
-
Method Summary
All Methods Instance Methods Concrete Methods 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(java.lang.Appendable appendable)
void
appendString(java.lang.Appendable appendable, java.lang.String separator)
void
appendString(java.lang.Appendable appendable, java.lang.String start, java.lang.String separator, java.lang.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)
java.lang.String
makeString()
java.lang.String
makeString(java.lang.String separator)
java.lang.String
makeString(java.lang.String start, java.lang.String separator, java.lang.String end)
java.lang.String
makeString(Function<? super T,java.lang.Object> function, java.lang.String start, java.lang.String separator, java.lang.String end)
T
max()
T
max(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>>
TmaxBy(Function<? super T,? extends V> function)
T
min()
T
min(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>>
TminBy(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.java.lang.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(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>>
MutableSortedBag<T>toSortedBagBy(Function<? super T,? extends V> function)
MutableList<T>
toSortedList()
MutableList<T>
toSortedList(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>>
MutableList<T>toSortedListBy(Function<? super T,? extends V> function)
<NK,NV>
MutableSortedMap<NK,NV>toSortedMap(java.util.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(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>>
MutableSortedSet<T>toSortedSetBy(Function<? super T,? extends V> function)
java.lang.String
toString()
protected <A> ParallelListIterable<A>
wrap(ParallelListIterable<A> wrapped)
protected <A> ParallelIterable<A>
wrap(ParallelIterable<A> wrapped)
protected <A> ParallelUnsortedSetIterable<A>
wrap(ParallelUnsortedSetIterable<A> wrapped)
-
Methods inherited from class java.lang.Object
clone, equals, finalize, 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
-
-
-
-
Field Detail
-
delegate
protected final PI extends ParallelIterable<T> delegate
-
lock
protected final java.util.concurrent.locks.ReadWriteLock lock
-
-
Constructor Detail
-
AbstractMultiReaderParallelIterable
protected AbstractMultiReaderParallelIterable(PI delegate, java.util.concurrent.locks.ReadWriteLock lock)
-
-
Method Detail
-
wrap
protected <A> ParallelListIterable<A> wrap(ParallelListIterable<A> wrapped)
-
wrap
protected <A> ParallelUnsortedSetIterable<A> wrap(ParallelUnsortedSetIterable<A> wrapped)
-
wrap
protected <A> ParallelIterable<A> wrap(ParallelIterable<A> wrapped)
-
forEach
public void forEach(Procedure<? super T> procedure)
- Specified by:
forEach
in interfaceParallelIterable<T>
-
forEachWith
public <P> void forEachWith(Procedure2<? super T,? super P> procedure, P parameter)
- Specified by:
forEachWith
in interfaceParallelIterable<T>
-
detect
public T detect(Predicate<? super T> predicate)
- Specified by:
detect
in interfaceParallelIterable<T>
-
detectWith
public <P> T detectWith(Predicate2<? super T,? super P> predicate, P parameter)
- Specified by:
detectWith
in interfaceParallelIterable<T>
-
detectIfNone
public T detectIfNone(Predicate<? super T> predicate, Function0<? extends T> function)
- Specified by:
detectIfNone
in interfaceParallelIterable<T>
-
detectWithIfNone
public <P> T detectWithIfNone(Predicate2<? super T,? super P> predicate, P parameter, Function0<? extends T> function)
- Specified by:
detectWithIfNone
in interfaceParallelIterable<T>
-
count
public int count(Predicate<? super T> predicate)
- Specified by:
count
in interfaceParallelIterable<T>
-
countWith
public <P> int countWith(Predicate2<? super T,? super P> predicate, P parameter)
- Specified by:
countWith
in interfaceParallelIterable<T>
-
anySatisfy
public boolean anySatisfy(Predicate<? super T> predicate)
- Specified by:
anySatisfy
in interfaceParallelIterable<T>
-
anySatisfyWith
public <P> boolean anySatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
- Specified by:
anySatisfyWith
in interfaceParallelIterable<T>
-
allSatisfy
public boolean allSatisfy(Predicate<? super T> predicate)
- Specified by:
allSatisfy
in interfaceParallelIterable<T>
-
allSatisfyWith
public <P> boolean allSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
- Specified by:
allSatisfyWith
in interfaceParallelIterable<T>
-
noneSatisfy
public boolean noneSatisfy(Predicate<? super T> predicate)
- Specified by:
noneSatisfy
in interfaceParallelIterable<T>
-
noneSatisfyWith
public <P> boolean noneSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
- Specified by:
noneSatisfyWith
in interfaceParallelIterable<T>
-
toList
public MutableList<T> toList()
- Specified by:
toList
in interfaceParallelIterable<T>
-
toSortedList
public MutableList<T> toSortedList()
- Specified by:
toSortedList
in interfaceParallelIterable<T>
-
toSortedList
public MutableList<T> toSortedList(java.util.Comparator<? super T> comparator)
- Specified by:
toSortedList
in interfaceParallelIterable<T>
-
toSortedListBy
public <V extends java.lang.Comparable<? super V>> MutableList<T> toSortedListBy(Function<? super T,? extends V> function)
- Specified by:
toSortedListBy
in interfaceParallelIterable<T>
-
toSet
public MutableSet<T> toSet()
- Specified by:
toSet
in interfaceParallelIterable<T>
-
toSortedSet
public MutableSortedSet<T> toSortedSet()
- Specified by:
toSortedSet
in interfaceParallelIterable<T>
-
toSortedSet
public MutableSortedSet<T> toSortedSet(java.util.Comparator<? super T> comparator)
- Specified by:
toSortedSet
in interfaceParallelIterable<T>
-
toSortedSetBy
public <V extends java.lang.Comparable<? super V>> MutableSortedSet<T> toSortedSetBy(Function<? super T,? extends V> function)
- Specified by:
toSortedSetBy
in interfaceParallelIterable<T>
-
toBag
public MutableBag<T> toBag()
- Specified by:
toBag
in interfaceParallelIterable<T>
-
toSortedBag
public MutableSortedBag<T> toSortedBag()
- Specified by:
toSortedBag
in interfaceParallelIterable<T>
-
toSortedBag
public MutableSortedBag<T> toSortedBag(java.util.Comparator<? super T> comparator)
- Specified by:
toSortedBag
in interfaceParallelIterable<T>
-
toSortedBagBy
public <V extends java.lang.Comparable<? super V>> MutableSortedBag<T> toSortedBagBy(Function<? super T,? extends V> function)
- Specified by:
toSortedBagBy
in interfaceParallelIterable<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 interfaceParallelIterable<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 interfaceParallelIterable<T>
-
toSortedMap
public <NK,NV> MutableSortedMap<NK,NV> toSortedMap(java.util.Comparator<? super NK> comparator, Function<? super T,? extends NK> keyFunction, Function<? super T,? extends NV> valueFunction)
- Specified by:
toSortedMap
in interfaceParallelIterable<T>
-
toArray
public java.lang.Object[] toArray()
- Specified by:
toArray
in interfaceParallelIterable<T>
-
toArray
public <T1> T1[] toArray(T1[] target)
- Specified by:
toArray
in interfaceParallelIterable<T>
-
min
public T min(java.util.Comparator<? super T> comparator)
- Specified by:
min
in interfaceParallelIterable<T>
-
max
public T max(java.util.Comparator<? super T> comparator)
- Specified by:
max
in interfaceParallelIterable<T>
-
min
public T min()
- Specified by:
min
in interfaceParallelIterable<T>
-
max
public T max()
- Specified by:
max
in interfaceParallelIterable<T>
-
minBy
public <V extends java.lang.Comparable<? super V>> T minBy(Function<? super T,? extends V> function)
- Specified by:
minBy
in interfaceParallelIterable<T>
-
maxBy
public <V extends java.lang.Comparable<? super V>> T maxBy(Function<? super T,? extends V> function)
- Specified by:
maxBy
in interfaceParallelIterable<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 interfaceParallelIterable<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 interfaceParallelIterable<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 interfaceParallelIterable<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 interfaceParallelIterable<T>
-
makeString
public java.lang.String makeString()
- Specified by:
makeString
in interfaceParallelIterable<T>
-
makeString
public java.lang.String makeString(java.lang.String separator)
- Specified by:
makeString
in interfaceParallelIterable<T>
-
makeString
public java.lang.String makeString(java.lang.String start, java.lang.String separator, java.lang.String end)
- Specified by:
makeString
in interfaceParallelIterable<T>
-
makeString
public java.lang.String makeString(Function<? super T,java.lang.Object> function, java.lang.String start, java.lang.String separator, java.lang.String end)
- Specified by:
makeString
in interfaceParallelIterable<T>
-
appendString
public void appendString(java.lang.Appendable appendable)
- Specified by:
appendString
in interfaceParallelIterable<T>
-
appendString
public void appendString(java.lang.Appendable appendable, java.lang.String separator)
- Specified by:
appendString
in interfaceParallelIterable<T>
-
appendString
public void appendString(java.lang.Appendable appendable, java.lang.String start, java.lang.String separator, java.lang.String end)
- Specified by:
appendString
in interfaceParallelIterable<T>
-
groupByUniqueKey
public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)
- Specified by:
groupByUniqueKey
in interfaceParallelIterable<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 interfaceParallelIterable<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 interfaceParallelIterable<T>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-