Class ListIterableParallelIterable<T>
java.lang.Object
org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,RootListBatch<T>>
org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable<T,RootListBatch<T>>
org.eclipse.collections.impl.lazy.parallel.list.ListIterableParallelIterable<T>
- All Implemented Interfaces:
ParallelListIterable<T>
,ParallelIterable<T>
public final class ListIterableParallelIterable<T>
extends AbstractParallelListIterable<T,RootListBatch<T>>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
private class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final int
private final ListIterable
<T> private final ExecutorService
-
Constructor Summary
ConstructorsConstructorDescriptionListIterableParallelIterable
(ListIterable<T> delegate, ExecutorService executorService, int batchSize) -
Method Summary
Modifier and TypeMethodDescriptionboolean
allSatisfy
(Predicate<? super T> predicate) boolean
anySatisfy
(Predicate<? super T> predicate) void
int
<V> ListMultimap
<V, T> <V> ListMultimap
<V, T> groupByEach
(Function<? super T, ? extends Iterable<V>> function) <V> MapIterable
<V, T> groupByUniqueKey
(Function<? super T, ? extends V> function) split()
Object[]
toArray()
<E> E[]
toArray
(E[] array) Methods inherited from class org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable
asUnique, collect, collectIf, collectWith, flatCollect, isOrdered, reject, rejectWith, select, selectInstancesOf, selectWith
Methods inherited from class org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable
aggregateBy, aggregateInPlaceBy, allSatisfy, allSatisfyWith, anySatisfy, anySatisfyWith, appendString, collectCombine, count, countWith, detect, detectIfNone, detectWith, detectWithIfNone, forEach, forEachWith, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy, toString
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
aggregateBy, aggregateInPlaceBy, allSatisfyWith, anySatisfyWith, appendString, appendString, appendString, count, countWith, detectIfNone, detectWith, detectWithIfNone, forEachWith, makeString, makeString, makeString, makeString, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy
-
Field Details
-
delegate
-
executorService
-
batchSize
private final int batchSize
-
-
Constructor Details
-
ListIterableParallelIterable
public ListIterableParallelIterable(ListIterable<T> delegate, ExecutorService executorService, int batchSize)
-
-
Method Details
-
getExecutorService
- Specified by:
getExecutorService
in classAbstractParallelIterable<T,
RootListBatch<T>>
-
split
- Specified by:
split
in classAbstractParallelIterable<T,
RootListBatch<T>>
-
forEach
-
anySatisfy
-
allSatisfy
-
detect
-
toArray
- Specified by:
toArray
in interfaceParallelIterable<T>
- Overrides:
toArray
in classAbstractParallelListIterable<T,
RootListBatch<T>>
-
toArray
public <E> E[] toArray(E[] array) - Specified by:
toArray
in interfaceParallelIterable<T>
- Overrides:
toArray
in classAbstractParallelListIterable<T,
RootListBatch<T>>
-
groupBy
- Specified by:
groupBy
in interfaceParallelIterable<T>
- Specified by:
groupBy
in interfaceParallelListIterable<T>
- Overrides:
groupBy
in classAbstractParallelListIterable<T,
RootListBatch<T>>
-
groupByEach
- Specified by:
groupByEach
in interfaceParallelIterable<T>
- Specified by:
groupByEach
in interfaceParallelListIterable<T>
- Overrides:
groupByEach
in classAbstractParallelListIterable<T,
RootListBatch<T>>
-
groupByUniqueKey
- Specified by:
groupByUniqueKey
in interfaceParallelIterable<T>
- Overrides:
groupByUniqueKey
in classAbstractParallelListIterable<T,
RootListBatch<T>>
-
getBatchSize
public int getBatchSize()- Specified by:
getBatchSize
in classAbstractParallelIterable<T,
RootListBatch<T>>
-