Class ParallelCollectUnsortedBag<T,V>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable<V, UnsortedBagBatch<V>>

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 final Function<? super T, ? extends V>	function
private final 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

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()
ExecutorService	getExecutorService()
LazyIterable<UnsortedBagBatch<V>>	split()

Methods inherited from class AbstractParallelUnsortedBag

asUnique, collect, collectIf, collectWith, flatCollect, groupBy, groupByEach, isOrdered, reject, rejectWith, select, selectInstancesOf, selectWith, toBag

Methods inherited from class 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface 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 Details

parallelIterable

private final AbstractParallelUnsortedBag<T, ? extends UnsortedBagBatch<T>> parallelIterable

function

private final Function<? super T, ? extends V> function

Constructor Details

ParallelCollectUnsortedBag

public ParallelCollectUnsortedBag(AbstractParallelUnsortedBag<T, ? extends UnsortedBagBatch<T>> parallelIterable,
 Function<? super T, ? extends V> function)

Method Details

getExecutorService

public ExecutorService getExecutorService()

Specified by:

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

getBatchSize

public int getBatchSize()

Specified by:

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

split

public LazyIterable<UnsortedBagBatch<V>> split()

Specified by:

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

forEach

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

forEachWithOccurrences

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

anySatisfy

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

allSatisfy

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

detect

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