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 Description

AbstractParallelIterable()

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)`
`<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 Details
- AbstractParallelIterable
  
  public AbstractParallelIterable()
Method Details
- getExecutorService
 
 public abstract ExecutorService getExecutorService()
- getBatchSize
 
 public abstract int getBatchSize()
- split
 
 public abstract LazyIterable 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 void forEachWith(Procedure2<? super T,? super P> procedure, P parameter)
 
 Specified by:
 
 forEachWith in interface ParallelIterable<T>
- anySatisfyWith
 
 public boolean anySatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
 
 Specified by:
 
 anySatisfyWith in interface ParallelIterable<T>
- allSatisfyWith
 
 public 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 boolean noneSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
 
 Specified by:
 
 noneSatisfyWith in interface ParallelIterable<T>
- detectWith
 
 public 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 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 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>

Class AbstractParallelIterable<T,​B extends Batch<T>>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Details

Method Details

Class AbstractParallelIterable<T,B extends Batch<T>>