Class ImmutableTreeSet.SortedSetIterableParallelIterable

java.lang.Object

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

org.eclipse.collections.impl.lazy.parallel.set.sorted.AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

org.eclipse.collections.impl.set.sorted.immutable.ImmutableTreeSet.SortedSetIterableParallelIterable

All Implemented Interfaces:

ParallelIterable<T>, ParallelSetIterable<T>, ParallelSortedSetIterable<T>

Enclosing class:

ImmutableTreeSet<T>

private final class ImmutableTreeSet.SortedSetIterableParallelIterable
extends AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ImmutableTreeSet.SortedSetIterableParallelIterable.SortedSetIterableParallelBatchIterator
private class	ImmutableTreeSet.SortedSetIterableParallelIterable.SortedSetIterableParallelBatchLazyIterable

Field Summary

Fields

Modifier and Type	Field	Description
private final int	batchSize
private final ExecutorService	executorService

Constructor Summary

Constructors

Modifier	Constructor	Description
private	SortedSetIterableParallelIterable(ExecutorService executorService, int batchSize)

Method Summary

Modifier and Type	Method	Description
boolean	allSatisfy(Predicate<? super T> predicate)
boolean	anySatisfy(Predicate<? super T> predicate)
Comparator<? super T>	comparator()
T	detect(Predicate<? super T> predicate)
void	forEach(Procedure<? super T> procedure)
int	getBatchSize()
ExecutorService	getExecutorService()
<V> ImmutableSortedSetMultimap<V,T>	groupBy(Function<? super T, ? extends V> function)
<V> ImmutableSortedSetMultimap<V,T>	groupByEach(Function<? super T, ? extends Iterable<V>> function)
<V> MapIterable<V,T>	groupByUniqueKey(Function<? super T, ? extends V> function)
LazyIterable<RootSortedSetBatch<T>>	split()
Object[]	toArray()
<E> E[]	toArray(E[] array)

Methods inherited from class AbstractParallelSortedSetIterable

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

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

executorService

private final ExecutorService executorService

batchSize

private final int batchSize

Constructor Details

SortedSetIterableParallelIterable

private SortedSetIterableParallelIterable(ExecutorService executorService,
 int batchSize)

Method Details

comparator

public Comparator<? super T> comparator()

getExecutorService

public ExecutorService getExecutorService()

Specified by:

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

split

public LazyIterable<RootSortedSetBatch<T>> split()

Specified by:

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

forEach

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

anySatisfy

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

allSatisfy

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

detect

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

toArray

public Object[] toArray()

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

toArray

public <E> E[] toArray(E[] array)

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

groupBy

public <V> ImmutableSortedSetMultimap<V,T> groupBy(Function<? super T, ? extends V> function)

Specified by:

groupBy in interface ParallelIterable<T>

Specified by:

groupBy in interface ParallelSetIterable<T>

Specified by:

groupBy in interface ParallelSortedSetIterable<T>

Overrides:

groupBy in class AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

groupByEach

public <V> ImmutableSortedSetMultimap<V,T> groupByEach(Function<? super T, ? extends Iterable<V>> function)

Specified by:

groupByEach in interface ParallelIterable<T>

Specified by:

groupByEach in interface ParallelSetIterable<T>

Specified by:

groupByEach in interface ParallelSortedSetIterable<T>

Overrides:

groupByEach in class AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

groupByUniqueKey

public <V> MapIterable<V,T> groupByUniqueKey(Function<? super T, ? extends V> function)

Specified by:

groupByUniqueKey in interface ParallelIterable<T>

Overrides:

groupByUniqueKey in class AbstractParallelSortedSetIterable<T, RootSortedSetBatch<T>>

getBatchSize

public int getBatchSize()

Specified by:

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