Class ParallelCollectUnsortedBag<T,V>
- java.lang.Object
-
- org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>
-
- org.eclipse.collections.impl.lazy.parallel.bag.AbstractParallelUnsortedBag<V,UnsortedBagBatch<V>>
-
- org.eclipse.collections.impl.lazy.parallel.bag.ParallelCollectUnsortedBag<T,V>
-
- All Implemented Interfaces:
ParallelBag<V>
,ParallelUnsortedBag<V>
,ParallelIterable<V>
public class ParallelCollectUnsortedBag<T,V> extends AbstractParallelUnsortedBag<V,UnsortedBagBatch<V>>
-
-
Field Summary
Fields Modifier and Type Field Description private Function<? super T,? extends V>
function
private AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>>
parallelIterable
-
Constructor Summary
Constructors Constructor Description ParallelCollectUnsortedBag(AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>> parallelIterable, Function<? super T,? extends V> function)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
allSatisfy(Predicate<? super V> predicate)
boolean
anySatisfy(Predicate<? super V> predicate)
V
detect(Predicate<? super V> predicate)
void
forEach(Procedure<? super V> procedure)
void
forEachWithOccurrences(ObjectIntProcedure<? super V> procedure)
int
getBatchSize()
java.util.concurrent.ExecutorService
getExecutorService()
LazyIterable<UnsortedBagBatch<V>>
split()
-
Methods inherited from class org.eclipse.collections.impl.lazy.parallel.bag.AbstractParallelUnsortedBag
asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, isOrdered, reject, rejectWith, select, selectInstancesOf, selectWith, toBag
-
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, toArray, 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, toArray, toArray, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy
-
-
-
-
Field Detail
-
parallelIterable
private final AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>> parallelIterable
-
-
Constructor Detail
-
ParallelCollectUnsortedBag
public ParallelCollectUnsortedBag(AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>> parallelIterable, Function<? super T,? extends V> function)
-
-
Method Detail
-
getExecutorService
public java.util.concurrent.ExecutorService getExecutorService()
- Specified by:
getExecutorService
in classAbstractParallelIterable<V,UnsortedBagBatch<V>>
-
getBatchSize
public int getBatchSize()
- Specified by:
getBatchSize
in classAbstractParallelIterable<V,UnsortedBagBatch<V>>
-
split
public LazyIterable<UnsortedBagBatch<V>> split()
- Specified by:
split
in classAbstractParallelIterable<V,UnsortedBagBatch<V>>
-
forEachWithOccurrences
public void forEachWithOccurrences(ObjectIntProcedure<? super V> procedure)
-
-