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

public abstract Class AbstractParallelIterable<T, B extends Batch<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.AbstractParallelIterableImpl, org.eclipse.collections.impl.lazy.parallel.bag.AbstractParallelUnsortedBag, org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable, org.eclipse.collections.impl.lazy.parallel.set.AbstractParallelUnsortedSetIterable, org.eclipse.collections.impl.lazy.parallel.set.sorted.AbstractParallelSortedSetIterable
Annotations
@Beta
Imports
java.io.IOException, java.util.Collections, .Comparator, .NoSuchElementException, .Set, java.util.concurrent.Callable, .CompletionService, .ExecutionException, .ExecutorCompletionService, .ExecutorService, .Future, org.eclipse.collections.api.LazyIterable, .ParallelIterable, org.eclipse.collections.api.annotation.Beta, 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.factory.Sets, .SortedBags, org.eclipse.collections.api.list.MutableList, org.eclipse.collections.api.map.MapIterable, .MutableMap, org.eclipse.collections.api.map.sorted.MutableSortedMap, org.eclipse.collections.api.set.MutableSet, org.eclipse.collections.api.set.sorted.MutableSortedSet, org.eclipse.collections.impl.Counter, org.eclipse.collections.impl.bag.mutable.HashBag, org.eclipse.collections.impl.bag.sorted.mutable.TreeBag, org.eclipse.collections.impl.block.factory.Comparators, .Functions2, .Predicates, .Procedures, org.eclipse.collections.impl.block.procedure.CollectionAddProcedure, .DoubleSumResultHolder, .MapCollectProcedure, .MutatingAggregationProcedure, .NonMutatingAggregationProcedure, org.eclipse.collections.impl.block.procedure.checked.CheckedProcedure2, org.eclipse.collections.impl.list.mutable.CompositeFastList, .FastList, org.eclipse.collections.impl.map.mutable.ConcurrentHashMap, .ConcurrentHashMapUnsafe, .UnifiedMap, org.eclipse.collections.impl.map.sorted.mutable.TreeSortedMap, org.eclipse.collections.impl.set.mutable.SetAdapter, org.eclipse.collections.impl.set.sorted.mutable.TreeSortedSet

Constructor Summary

AccessConstructor and Description
public
AbstractParallelIterable()

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.

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

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

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

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

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

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

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

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

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)

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.

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

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.

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

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

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

public abstract int
getBatchSize()

public abstract ExecutorService
getExecutorService()

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

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

protected abstract boolean
isOrdered()

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 abstract LazyIterable<B>
split()

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.

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

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.

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

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

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(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.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Constructor Detail

AbstractParallelIterableback to summary
public AbstractParallelIterable()

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
protected static <T> boolean allSatisfy(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Predicate<? super T> predicate)
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
protected static <T> boolean anySatisfy(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Predicate<? super T> predicate)
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, String start, String separator, String end)

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

Annotations
@Override
collectCombineback to summary
protected <S, V> void collectCombine(Function<Batch<T>, V> function, Procedure2<S, V> combineProcedure, S state)
collectCombineOrderedback to summary
private <S, V> void collectCombineOrdered(Function<Batch<T>, V> function, Procedure2<S, V> combineProcedure, S state)
collectCombineUnorderedback to summary
private <S, V> void collectCombineUnordered(Function<Batch<T>, V> function, Procedure2<S, V> combineProcedure, S state)
collectReduceback to summary
private T collectReduce(Function<Batch<T>, T> map, Function2<T, T, T> function2)
collectReduceOrderedback to summary
private T collectReduceOrdered(Function<Batch<T>, T> map, Function2<T, T, T> function2)
collectReduceUnorderedback to summary
private T collectReduceUnordered(Function<Batch<T>, T> map, Function2<T, T, T> function2)
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
protected static <T> T detect(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Predicate<? super T> predicate)
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
protected static <T> void forEach(AbstractParallelIterable<T, ? extends RootBatch<T>> parallelIterable, Procedure<? super T> procedure)
forEachWithback to summary
public <P> void forEachWith(Procedure2<? super T, ? super P> procedure, P parameter)

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

Annotations
@Override
getBatchSizeback to summary
public abstract int getBatchSize()
getExecutorServiceback to summary
public abstract ExecutorService getExecutorService()
groupByUniqueKeyback to summary
public <V> MapIterable<V, T> groupByUniqueKey(Function<? super T, ? extends V> function)

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

Annotations
@Override
isOrderedback to summary
protected abstract boolean isOrdered()
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
splitback to summary
public abstract LazyIterable<B> split()
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
sumOfDoubleOrderedback to summary
private double sumOfDoubleOrdered(Function<Batch<T>, DoubleSumResultHolder> map)
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
sumOfLongOrderedback to summary
private long sumOfLongOrdered(LongFunction<Batch<T>> map)
toArrayback to summary
public <E> E[] toArray(E[] array)

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