Class ListIterableParallelIterable<T>
- java.lang.Object
-
- org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>
-
- 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 Classes Modifier and Type Class Description private class
ListIterableParallelIterable.ListIterableParallelBatchIterator
private class
ListIterableParallelIterable.ListIterableParallelBatchLazyIterable
-
Field Summary
Fields Modifier and Type Field Description private int
batchSize
private ListIterable<T>
delegate
private java.util.concurrent.ExecutorService
executorService
-
Constructor Summary
Constructors Constructor Description ListIterableParallelIterable(ListIterable<T> delegate, java.util.concurrent.ExecutorService executorService, int batchSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
allSatisfy(Predicate<? super T> predicate)
boolean
anySatisfy(Predicate<? super T> predicate)
T
detect(Predicate<? super T> predicate)
void
forEach(Procedure<? super T> procedure)
int
getBatchSize()
java.util.concurrent.ExecutorService
getExecutorService()
<V> ListMultimap<V,T>
groupBy(Function<? super T,? extends V> function)
<V> ListMultimap<V,T>
groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
<V> MapIterable<V,T>
groupByUniqueKey(Function<? super T,? extends V> function)
LazyIterable<RootListBatch<T>>
split()
java.lang.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 Detail
-
delegate
private final ListIterable<T> delegate
-
executorService
private final java.util.concurrent.ExecutorService executorService
-
batchSize
private final int batchSize
-
-
Constructor Detail
-
ListIterableParallelIterable
public ListIterableParallelIterable(ListIterable<T> delegate, java.util.concurrent.ExecutorService executorService, int batchSize)
-
-
Method Detail
-
getExecutorService
public java.util.concurrent.ExecutorService getExecutorService()
- Specified by:
getExecutorService
in classAbstractParallelIterable<T,RootListBatch<T>>
-
split
public LazyIterable<RootListBatch<T>> split()
- Specified by:
split
in classAbstractParallelIterable<T,RootListBatch<T>>
-
toArray
public java.lang.Object[] 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
public <V> ListMultimap<V,T> groupBy(Function<? super T,? extends V> function)
- Specified by:
groupBy
in interfaceParallelIterable<T>
- Specified by:
groupBy
in interfaceParallelListIterable<T>
- Overrides:
groupBy
in classAbstractParallelListIterable<T,RootListBatch<T>>
-
groupByEach
public <V> ListMultimap<V,T> groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
- Specified by:
groupByEach
in interfaceParallelIterable<T>
- Specified by:
groupByEach
in interfaceParallelListIterable<T>
- Overrides:
groupByEach
in classAbstractParallelListIterable<T,RootListBatch<T>>
-
groupByUniqueKey
public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T,? extends V> function)
- 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>>
-
-