Package org.eclipse.collections.impl.lazy.parallel.bag

Class ParallelSelectUnsortedBag<T>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<T,B>

org.eclipse.collections.impl.lazy.parallel.bag.AbstractParallelUnsortedBag<T,UnsortedBagBatch<T>>

org.eclipse.collections.impl.lazy.parallel.bag.ParallelSelectUnsortedBag<T>

All Implemented Interfaces:

ParallelBag<T>, ParallelUnsortedBag<T>, ParallelIterable<T>

class ParallelSelectUnsortedBag<T>
extends AbstractParallelUnsortedBag<T,UnsortedBagBatch<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	ParallelSelectUnsortedBag.SelectAllSatisfyPredicate<T>

Field Summary

Fields

Modifier and Type	Field	Description
private AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>>	parallelIterable
private Predicate<? super T>	predicate

Constructor Summary

Constructors

Constructor	Description
ParallelSelectUnsortedBag(AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>> parallelIterable, Predicate<? super T> predicate)

Method Summary

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)
void	forEachWithOccurrences(ObjectIntProcedure<? super T> procedure)
int	getBatchSize()
java.util.concurrent.ExecutorService	getExecutorService()
LazyIterable<UnsortedBagBatch<T>>	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

predicate

private final Predicate<? super T> predicate

Constructor Detail

ParallelSelectUnsortedBag

ParallelSelectUnsortedBag(AbstractParallelUnsortedBag<T,? extends UnsortedBagBatch<T>> parallelIterable,
                          Predicate<? super T> predicate)

Method Detail

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

Specified by:

getExecutorService in class AbstractParallelIterable<T,UnsortedBagBatch<T>>

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in class AbstractParallelIterable<T,UnsortedBagBatch<T>>

forEach

public void forEach(Procedure<? super T> procedure)

forEachWithOccurrences

public void forEachWithOccurrences(ObjectIntProcedure<? super T> procedure)

anySatisfy

public boolean anySatisfy(Predicate<? super T> predicate)

allSatisfy

public boolean allSatisfy(Predicate<? super T> predicate)

split

public LazyIterable<UnsortedBagBatch<T>> split()

Specified by:

split in class AbstractParallelIterable<T,UnsortedBagBatch<T>>

detect

public T detect(Predicate<? super T> predicate)