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

Class ListIterableParallelIterable<T>

java.lang.Object

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

org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable<T,RootListBatch<T>>

org.eclipse.collections.impl.lazy.parallel.list.ListIterableParallelIterable<T>

All Implemented Interfaces:

ParallelListIterable<T>, ParallelIterable<T>

public final class ListIterableParallelIterable<T>
extends AbstractParallelListIterable<T,RootListBatch<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	ListIterableParallelIterable.ListIterableParallelBatchIterator
private class	ListIterableParallelIterable.ListIterableParallelBatchLazyIterable

Field Summary

Fields

Modifier and Type	Field	Description
private int	batchSize
private ListIterable<T>	delegate
private java.util.concurrent.ExecutorService	executorService

Constructor Summary

Constructors

Constructor	Description
ListIterableParallelIterable(ListIterable<T> delegate, java.util.concurrent.ExecutorService executorService, int batchSize)

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)
int	getBatchSize()
java.util.concurrent.ExecutorService	getExecutorService()
<V> ListMultimap<V,T>	groupBy(Function<? super T,? extends V> function)
<V> ListMultimap<V,T>	groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
<V> MapIterable<V,T>	groupByUniqueKey(Function<? super T,? extends V> function)
LazyIterable<RootListBatch<T>>	split()
java.lang.Object[]	toArray()
<E> E[]	toArray(E[] array)

Methods inherited from class org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable

asUnique, collect, collectIf, collectWith, flatCollect, 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, 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, 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 Detail

delegate

private final ListIterable<T> delegate

executorService

private final java.util.concurrent.ExecutorService executorService

batchSize

private final int batchSize

Constructor Detail

ListIterableParallelIterable

public ListIterableParallelIterable(ListIterable<T> delegate,
                                    java.util.concurrent.ExecutorService executorService,
                                    int batchSize)

Method Detail

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

Specified by:

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

split

public LazyIterable<RootListBatch<T>> split()

Specified by:

split in class AbstractParallelIterable<T,RootListBatch<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 java.lang.Object[] toArray()

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelListIterable<T,RootListBatch<T>>

toArray

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

Specified by:

toArray in interface ParallelIterable<T>

Overrides:

toArray in class AbstractParallelListIterable<T,RootListBatch<T>>

groupBy

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

Specified by:

groupBy in interface ParallelIterable<T>

Specified by:

groupBy in interface ParallelListIterable<T>

Overrides:

groupBy in class AbstractParallelListIterable<T,RootListBatch<T>>

groupByEach

public <V> ListMultimap<V,T> groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)

Specified by:

groupByEach in interface ParallelIterable<T>

Specified by:

groupByEach in interface ParallelListIterable<T>

Overrides:

groupByEach in class AbstractParallelListIterable<T,RootListBatch<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 AbstractParallelListIterable<T,RootListBatch<T>>

getBatchSize

public int getBatchSize()

Specified by:

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