Top Fields Constructors Methods
org.eclipse.collections.impl.lazy.parallel

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

extends Object
implements ParallelIterable<T>
Class Inheritance
All Implemented Interfaces
org.eclipse.collections.api.ParallelIterable
Known Direct Subclasses
org.eclipse.collections.impl.lazy.parallel.MultiReaderParallelIterable, org.eclipse.collections.impl.lazy.parallel.list.MultiReaderParallelListIterable, org.eclipse.collections.impl.lazy.parallel.set.MultiReaderParallelUnsortedSetIterable
Imports
java.util.Comparator, java.util.concurrent.locks.ReadWriteLock, org.eclipse.collections.api.ParallelIterable, org.eclipse.collections.api.bag.MutableBag, org.eclipse.collections.api.bag.sorted.MutableSortedBag, org.eclipse.collections.api.block.function.Function, .Function0, .Function2, org.eclipse.collections.api.block.function.primitive.DoubleFunction, .FloatFunction, .IntFunction, .LongFunction, org.eclipse.collections.api.block.predicate.Predicate, .Predicate2, org.eclipse.collections.api.block.procedure.Procedure, .Procedure2, org.eclipse.collections.api.list.MutableList, .ParallelListIterable, org.eclipse.collections.api.map.MapIterable, .MutableMap, org.eclipse.collections.api.map.sorted.MutableSortedMap, org.eclipse.collections.api.set.MutableSet, .ParallelUnsortedSetIterable, org.eclipse.collections.api.set.sorted.MutableSortedSet, org.eclipse.collections.impl.lazy.parallel.list.MultiReaderParallelListIterable, org.eclipse.collections.impl.lazy.parallel.set.MultiReaderParallelUnsortedSetIterable

Field Summary

Modifier and TypeField and Description
protected final PI
delegate

protected final ReadWriteLock
lock

Constructor Summary

AccessConstructor and Description
protected
AbstractMultiReaderParallelIterable(PI delegate, ReadWriteLock lock)

Method Summary

Modifier and TypeMethod and Description
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)

Implements org.eclipse.collections.api.ParallelIterable.aggregateBy.

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

Implements org.eclipse.collections.api.ParallelIterable.aggregateInPlaceBy.

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

Implements org.eclipse.collections.api.ParallelIterable.allSatisfy.

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

Implements org.eclipse.collections.api.ParallelIterable.allSatisfyWith.

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

Implements org.eclipse.collections.api.ParallelIterable.anySatisfy.

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

Implements org.eclipse.collections.api.ParallelIterable.anySatisfyWith.

public void
appendString(Appendable appendable)

Overrides default org.eclipse.collections.api.ParallelIterable.appendString.

public void
appendString(Appendable appendable, String separator)

Overrides default org.eclipse.collections.api.ParallelIterable.appendString.

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

Implements org.eclipse.collections.api.ParallelIterable.appendString.

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

Implements org.eclipse.collections.api.ParallelIterable.count.

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

Implements org.eclipse.collections.api.ParallelIterable.countWith.

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

Implements org.eclipse.collections.api.ParallelIterable.detect.

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

Implements org.eclipse.collections.api.ParallelIterable.detectIfNone.

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

Implements org.eclipse.collections.api.ParallelIterable.detectWith.

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

Implements org.eclipse.collections.api.ParallelIterable.detectWithIfNone.

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

Implements org.eclipse.collections.api.ParallelIterable.forEach.

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

Implements org.eclipse.collections.api.ParallelIterable.forEachWith.

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

Implements org.eclipse.collections.api.ParallelIterable.groupByUniqueKey.

public String
makeString()

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

public String
makeString(String separator)

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

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

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

public String
makeString(Function<? super T, Object> function, String start, String separator, String end)

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

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

Implements org.eclipse.collections.api.ParallelIterable.max.

public T
max()

Implements org.eclipse.collections.api.ParallelIterable.max.

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

Implements org.eclipse.collections.api.ParallelIterable.maxBy.

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

Implements org.eclipse.collections.api.ParallelIterable.min.

public T
min()

Implements org.eclipse.collections.api.ParallelIterable.min.

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

Implements org.eclipse.collections.api.ParallelIterable.minBy.

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

Implements org.eclipse.collections.api.ParallelIterable.noneSatisfy.

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

Implements org.eclipse.collections.api.ParallelIterable.noneSatisfyWith.

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

Implements org.eclipse.collections.api.ParallelIterable.sumOfDouble.

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

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

Implements org.eclipse.collections.api.ParallelIterable.sumOfFloat.

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

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

Implements org.eclipse.collections.api.ParallelIterable.sumOfInt.

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

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

Implements org.eclipse.collections.api.ParallelIterable.sumOfLong.

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

public Object[]
toArray()

Overrides default org.eclipse.collections.api.ParallelIterable.toArray.

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

Implements org.eclipse.collections.api.ParallelIterable.toArray.

public MutableBag<T>
toBag()

Implements org.eclipse.collections.api.ParallelIterable.toBag.

public MutableList<T>
toList()

Implements org.eclipse.collections.api.ParallelIterable.toList.

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

Implements org.eclipse.collections.api.ParallelIterable.toMap.

public MutableSet<T>
toSet()

Implements org.eclipse.collections.api.ParallelIterable.toSet.

public MutableSortedBag<T>
toSortedBag()

Implements org.eclipse.collections.api.ParallelIterable.toSortedBag.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedBag.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedBagBy.

public MutableList<T>
toSortedList()

Overrides default org.eclipse.collections.api.ParallelIterable.toSortedList.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedList.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedListBy.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedMap.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedMap.

public MutableSortedSet<T>
toSortedSet()

Implements org.eclipse.collections.api.ParallelIterable.toSortedSet.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedSet.

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

Implements org.eclipse.collections.api.ParallelIterable.toSortedSetBy.

public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.

protected <A> ParallelListIterable<A>
wrap(ParallelListIterable<A> wrapped)

protected <A> ParallelUnsortedSetIterable<A>
wrap(ParallelUnsortedSetIterable<A> wrapped)

protected <A> ParallelIterable<A>
wrap(ParallelIterable<A> wrapped)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Field Detail

delegateback to summary
protected final PI delegate
lockback to summary
protected final ReadWriteLock lock

Constructor Detail

AbstractMultiReaderParallelIterableback to summary
protected AbstractMultiReaderParallelIterable(PI delegate, ReadWriteLock lock)

Method Detail

aggregateByback to summary
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)

Implements org.eclipse.collections.api.ParallelIterable.aggregateBy.

Annotations
@Override
aggregateInPlaceByback to summary
public <K, V> MapIterable<K, V> aggregateInPlaceBy(Function<? super T, ? extends K> groupBy, Function0<? extends V> zeroValueFactory, Procedure2<? super V, ? super T> mutatingAggregator)

Implements org.eclipse.collections.api.ParallelIterable.aggregateInPlaceBy.

Annotations
@Override
allSatisfyback to summary
public boolean allSatisfy(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.allSatisfy.

Annotations
@Override
allSatisfyWithback to summary
public <P> boolean allSatisfyWith(Predicate2<? super T, ? super P> predicate, P parameter)

Implements org.eclipse.collections.api.ParallelIterable.allSatisfyWith.

Annotations
@Override
anySatisfyback to summary
public boolean anySatisfy(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.anySatisfy.

Annotations
@Override
anySatisfyWithback to summary
public <P> boolean anySatisfyWith(Predicate2<? super T, ? super P> predicate, P parameter)

Implements org.eclipse.collections.api.ParallelIterable.anySatisfyWith.

Annotations
@Override
appendStringback to summary
public void appendString(Appendable appendable)

Overrides default org.eclipse.collections.api.ParallelIterable.appendString.

Annotations
@Override
appendStringback to summary
public void appendString(Appendable appendable, String separator)

Overrides default org.eclipse.collections.api.ParallelIterable.appendString.

Annotations
@Override
appendStringback to summary
public void appendString(Appendable appendable, String start, String separator, String end)

Implements org.eclipse.collections.api.ParallelIterable.appendString.

Annotations
@Override
countback to summary
public int count(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.count.

Annotations
@Override
countWithback to summary
public <P> int countWith(Predicate2<? super T, ? super P> predicate, P parameter)

Implements org.eclipse.collections.api.ParallelIterable.countWith.

Annotations
@Override
detectback to summary
public T detect(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.detect.

Annotations
@Override
detectIfNoneback to summary
public T detectIfNone(Predicate<? super T> predicate, Function0<? extends T> function)

Implements org.eclipse.collections.api.ParallelIterable.detectIfNone.

Annotations
@Override
detectWithback to summary
public <P> T detectWith(Predicate2<? super T, ? super P> predicate, P parameter)

Implements org.eclipse.collections.api.ParallelIterable.detectWith.

Annotations
@Override
detectWithIfNoneback to summary
public <P> T detectWithIfNone(Predicate2<? super T, ? super P> predicate, P parameter, Function0<? extends T> function)

Implements org.eclipse.collections.api.ParallelIterable.detectWithIfNone.

Annotations
@Override
forEachback to summary
public void forEach(Procedure<? super T> procedure)

Implements org.eclipse.collections.api.ParallelIterable.forEach.

Annotations
@Override
forEachWithback to summary
public <P> void forEachWith(Procedure2<? super T, ? super P> procedure, P parameter)

Implements org.eclipse.collections.api.ParallelIterable.forEachWith.

Annotations
@Override
groupByUniqueKeyback to summary
public <V> MapIterable<V, T> groupByUniqueKey(Function<? super T, ? extends V> function)

Implements org.eclipse.collections.api.ParallelIterable.groupByUniqueKey.

Annotations
@Override
makeStringback to summary
public String makeString()

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

Annotations
@Override
makeStringback to summary
public String makeString(String separator)

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

Annotations
@Override
makeStringback to summary
public String makeString(String start, String separator, String end)

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

Annotations
@Override
makeStringback to summary
public String makeString(Function<? super T, Object> function, String start, String separator, String end)

Overrides default org.eclipse.collections.api.ParallelIterable.makeString.

Annotations
@Override
maxback to summary
public T max(Comparator<? super T> comparator)

Implements org.eclipse.collections.api.ParallelIterable.max.

Annotations
@Override
maxback to summary
public T max()

Implements org.eclipse.collections.api.ParallelIterable.max.

Annotations
@Override
maxByback to summary
public <V extends Comparable<? super V>> T maxBy(Function<? super T, ? extends V> function)

Implements org.eclipse.collections.api.ParallelIterable.maxBy.

Annotations
@Override
minback to summary
public T min(Comparator<? super T> comparator)

Implements org.eclipse.collections.api.ParallelIterable.min.

Annotations
@Override
minback to summary
public T min()

Implements org.eclipse.collections.api.ParallelIterable.min.

Annotations
@Override
minByback to summary
public <V extends Comparable<? super V>> T minBy(Function<? super T, ? extends V> function)

Implements org.eclipse.collections.api.ParallelIterable.minBy.

Annotations
@Override
noneSatisfyback to summary
public boolean noneSatisfy(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.noneSatisfy.

Annotations
@Override
noneSatisfyWithback to summary
public <P> boolean noneSatisfyWith(Predicate2<? super T, ? super P> predicate, P parameter)

Implements org.eclipse.collections.api.ParallelIterable.noneSatisfyWith.

Annotations
@Override
sumOfDoubleback to summary
public double sumOfDouble(DoubleFunction<? super T> function)

Implements org.eclipse.collections.api.ParallelIterable.sumOfDouble.

Doc from org.eclipse.collections.api.ParallelIterable.sumOfDouble.

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.

Annotations
@Override
sumOfFloatback to summary
public double sumOfFloat(FloatFunction<? super T> function)

Implements org.eclipse.collections.api.ParallelIterable.sumOfFloat.

Doc from org.eclipse.collections.api.ParallelIterable.sumOfFloat.

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.

Annotations
@Override
sumOfIntback to summary
public long sumOfInt(IntFunction<? super T> function)

Implements org.eclipse.collections.api.ParallelIterable.sumOfInt.

Doc from org.eclipse.collections.api.ParallelIterable.sumOfInt.

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

Annotations
@Override
sumOfLongback to summary
public long sumOfLong(LongFunction<? super T> function)

Implements org.eclipse.collections.api.ParallelIterable.sumOfLong.

Doc from org.eclipse.collections.api.ParallelIterable.sumOfLong.

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

Annotations
@Override
toArrayback to summary
public Object[] toArray()

Overrides default org.eclipse.collections.api.ParallelIterable.toArray.

Annotations
@Override
toArrayback to summary
public <T1> T1[] toArray(T1[] target)

Implements org.eclipse.collections.api.ParallelIterable.toArray.

Annotations
@Override
toBagback to summary
public MutableBag<T> toBag()

Implements org.eclipse.collections.api.ParallelIterable.toBag.

Annotations
@Override
toListback to summary
public MutableList<T> toList()

Implements org.eclipse.collections.api.ParallelIterable.toList.

Annotations
@Override
toMapback to summary
public <NK, NV> MutableMap<NK, NV> toMap(Function<? super T, ? extends NK> keyFunction, Function<? super T, ? extends NV> valueFunction)

Implements org.eclipse.collections.api.ParallelIterable.toMap.

Annotations
@Override
toSetback to summary
public MutableSet<T> toSet()

Implements org.eclipse.collections.api.ParallelIterable.toSet.

Annotations
@Override
toSortedBagback to summary
public MutableSortedBag<T> toSortedBag()

Implements org.eclipse.collections.api.ParallelIterable.toSortedBag.

Annotations
@Override
toSortedBagback to summary
public MutableSortedBag<T> toSortedBag(Comparator<? super T> comparator)

Implements org.eclipse.collections.api.ParallelIterable.toSortedBag.

Annotations
@Override
toSortedBagByback to summary
public <V extends Comparable<? super V>> MutableSortedBag<T> toSortedBagBy(Function<? super T, ? extends V> function)

Implements org.eclipse.collections.api.ParallelIterable.toSortedBagBy.

Annotations
@Override
toSortedListback to summary
public MutableList<T> toSortedList()

Overrides default org.eclipse.collections.api.ParallelIterable.toSortedList.

Annotations
@Override
toSortedListback to summary
public MutableList<T> toSortedList(Comparator<? super T> comparator)

Implements org.eclipse.collections.api.ParallelIterable.toSortedList.

Annotations
@Override
toSortedListByback to summary
public <V extends Comparable<? super V>> MutableList<T> toSortedListBy(Function<? super T, ? extends V> function)

Implements org.eclipse.collections.api.ParallelIterable.toSortedListBy.

Annotations
@Override
toSortedMapback to summary
public <NK, NV> MutableSortedMap<NK, NV> toSortedMap(Function<? super T, ? extends NK> keyFunction, Function<? super T, ? extends NV> valueFunction)

Implements org.eclipse.collections.api.ParallelIterable.toSortedMap.

Annotations
@Override
toSortedMapback to summary
public <NK, NV> MutableSortedMap<NK, NV> toSortedMap(Comparator<? super NK> comparator, Function<? super T, ? extends NK> keyFunction, Function<? super T, ? extends NV> valueFunction)

Implements org.eclipse.collections.api.ParallelIterable.toSortedMap.

Annotations
@Override
toSortedSetback to summary
public MutableSortedSet<T> toSortedSet()

Implements org.eclipse.collections.api.ParallelIterable.toSortedSet.

Annotations
@Override
toSortedSetback to summary
public MutableSortedSet<T> toSortedSet(Comparator<? super T> comparator)

Implements org.eclipse.collections.api.ParallelIterable.toSortedSet.

Annotations
@Override
toSortedSetByback to summary
public <V extends Comparable<? super V>> MutableSortedSet<T> toSortedSetBy(Function<? super T, ? extends V> function)

Implements org.eclipse.collections.api.ParallelIterable.toSortedSetBy.

Annotations
@Override
toStringback to summary
public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Annotations
@Override
wrapback to summary
protected <A> ParallelListIterable<A> wrap(ParallelListIterable<A> wrapped)
wrapback to summary
protected <A> ParallelUnsortedSetIterable<A> wrap(ParallelUnsortedSetIterable<A> wrapped)
wrapback to summary
protected <A> ParallelIterable<A> wrap(ParallelIterable<A> wrapped)