Class UnifiedSet.UnifiedSetParallelUnsortedIterable
- java.lang.Object
-
- org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>
-
- org.eclipse.collections.impl.lazy.parallel.set.AbstractParallelUnsortedSetIterable<T,RootUnsortedSetBatch<T>>
-
- org.eclipse.collections.impl.set.mutable.UnifiedSet.UnifiedSetParallelUnsortedIterable
-
- All Implemented Interfaces:
ParallelIterable<T>
,ParallelSetIterable<T>
,ParallelUnsortedSetIterable<T>
- Enclosing class:
- UnifiedSet<T>
private final class UnifiedSet.UnifiedSetParallelUnsortedIterable extends AbstractParallelUnsortedSetIterable<T,RootUnsortedSetBatch<T>>
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
UnifiedSet.UnifiedSetParallelUnsortedIterable.UnifiedSetParallelSplitIterator
private class
UnifiedSet.UnifiedSetParallelUnsortedIterable.UnifiedSetParallelSplitLazyIterable
-
Field Summary
Fields Modifier and Type Field Description private int
batchSize
private java.util.concurrent.ExecutorService
executorService
-
Constructor Summary
Constructors Modifier Constructor Description private
UnifiedSetParallelUnsortedIterable(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()
LazyIterable<RootUnsortedSetBatch<T>>
split()
java.lang.Object[]
toArray()
<E> E[]
toArray(E[] array)
-
Methods inherited from class org.eclipse.collections.impl.lazy.parallel.set.AbstractParallelUnsortedSetIterable
asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, 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, groupByUniqueKey, 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, groupByUniqueKey, 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
-
-
-
-
Method Detail
-
getExecutorService
public java.util.concurrent.ExecutorService getExecutorService()
- Specified by:
getExecutorService
in classAbstractParallelIterable<T,RootUnsortedSetBatch<T>>
-
getBatchSize
public int getBatchSize()
- Specified by:
getBatchSize
in classAbstractParallelIterable<T,RootUnsortedSetBatch<T>>
-
split
public LazyIterable<RootUnsortedSetBatch<T>> split()
- Specified by:
split
in classAbstractParallelIterable<T,RootUnsortedSetBatch<T>>
-
toArray
public java.lang.Object[] toArray()
-
toArray
public <E> E[] toArray(E[] array)
- Specified by:
toArray
in interfaceParallelIterable<T>
- Overrides:
toArray
in classAbstractParallelIterable<T,RootUnsortedSetBatch<T>>
-
-