com.gs.collections.api

Interface ParallelIterable<T>

All Known Subinterfaces:

ParallelBag<T>, ParallelListIterable<T>, ParallelSetIterable<T>, ParallelSortedBag<T>, ParallelSortedSetIterable<T>, ParallelUnsortedBag<T>, ParallelUnsortedSetIterable<T>

public interface ParallelIterable<T>

A ParallelIterable is RichIterable which will defer evaluation for certain methods like select, reject, collect, etc. Any methods that do not return a ParallelIterable when called will cause evaluation to be forced. Evaluation occurs in parallel. All code blocks passed in must be stateless or thread-safe.

Since:

5.0

Method Summary

Methods

Modifier and Type	Method and Description
<K,V> MapIterable<K,V>	aggregateBy(Function<? super T,? extends K> groupBy, Function0<? extends V> zeroValueFactory, Function2<? super V,? super T,? extends V> nonMutatingAggregator)
<K,V> MapIterable<K,V>	aggregateInPlaceBy(Function<? super T,? extends K> groupBy, Function0<? extends V> zeroValueFactory, Procedure2<? super V,? super T> mutatingAggregator)
boolean	allSatisfy(Predicate<? super T> predicate)
<P> boolean	allSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
boolean	anySatisfy(Predicate<? super T> predicate)
<P> boolean	anySatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
void	appendString(java.lang.Appendable appendable)
void	appendString(java.lang.Appendable appendable, java.lang.String separator)
void	appendString(java.lang.Appendable appendable, java.lang.String start, java.lang.String separator, java.lang.String end)
ParallelIterable<T>	asUnique()
<V> ParallelIterable<V>	collect(Function<? super T,? extends V> function) Creates a parallel iterable for collecting elements from the current iterable.
<V> ParallelIterable<V>	collectIf(Predicate<? super T> predicate, Function<? super T,? extends V> function) Creates a parallel iterable for selecting and collecting elements from the current iterable.
<P,V> ParallelIterable<V>	collectWith(Function2<? super T,? super P,? extends V> function, P parameter)
int	count(Predicate<? super T> predicate)
<P> int	countWith(Predicate2<? super T,? super P> predicate, P parameter)
T	detect(Predicate<? super T> predicate)
T	detectIfNone(Predicate<? super T> predicate, Function0<? extends T> function)
<P> T	detectWith(Predicate2<? super T,? super P> predicate, P parameter)
<P> T	detectWithIfNone(Predicate2<? super T,? super P> predicate, P parameter, Function0<? extends T> function)
<V> ParallelIterable<V>	flatCollect(Function<? super T,? extends java.lang.Iterable<V>> function) Creates a parallel flattening iterable for the current iterable.
void	forEach(Procedure<? super T> procedure)
<P> void	forEachWith(Procedure2<? super T,? super P> procedure, P parameter)
<V> Multimap<V,T>	groupBy(Function<? super T,? extends V> function)
<V> Multimap<V,T>	groupByEach(Function<? super T,? extends java.lang.Iterable<V>> function)
<V> MapIterable<V,T>	groupByUniqueKey(Function<? super T,? extends V> function)
java.lang.String	makeString()
java.lang.String	makeString(java.lang.String separator)
java.lang.String	makeString(java.lang.String start, java.lang.String separator, java.lang.String end)
T	max()
T	max(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>> T	maxBy(Function<? super T,? extends V> function)
T	min()
T	min(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>> T	minBy(Function<? super T,? extends V> function)
boolean	noneSatisfy(Predicate<? super T> predicate)
<P> boolean	noneSatisfyWith(Predicate2<? super T,? super P> predicate, P parameter)
ParallelIterable<T>	reject(Predicate<? super T> predicate) Creates a parallel iterable for rejecting elements from the current iterable.
<P> ParallelIterable<T>	rejectWith(Predicate2<? super T,? super P> predicate, P parameter)
ParallelIterable<T>	select(Predicate<? super T> predicate) Creates a parallel iterable for selecting elements from the current iterable.
<S> ParallelIterable<S>	selectInstancesOf(java.lang.Class<S> clazz)
<P> ParallelIterable<T>	selectWith(Predicate2<? super T,? super P> predicate, P parameter)
double	sumOfDouble(DoubleFunction<? super T> function)
double	sumOfFloat(FloatFunction<? super T> function)
long	sumOfInt(IntFunction<? super T> function)
long	sumOfLong(LongFunction<? super T> function)
java.lang.Object[]	toArray()
<T1> T1[]	toArray(T1[] target)
MutableBag<T>	toBag()
MutableList<T>	toList()
<NK,NV> MutableMap<NK,NV>	toMap(Function<? super T,? extends NK> keyFunction, Function<? super T,? extends NV> valueFunction)
MutableSet<T>	toSet()
MutableList<T>	toSortedList()
MutableList<T>	toSortedList(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>> MutableList<T>	toSortedListBy(Function<? super T,? extends V> function)
<NK,NV> MutableSortedMap<NK,NV>	toSortedMap(java.util.Comparator<? super NK> comparator, Function<? super T,? extends NK> keyFunction, Function<? super T,? extends NV> valueFunction)
<NK,NV> MutableSortedMap<NK,NV>	toSortedMap(Function<? super T,? extends NK> keyFunction, Function<? super T,? extends NV> valueFunction)
MutableSortedSet<T>	toSortedSet()
MutableSortedSet<T>	toSortedSet(java.util.Comparator<? super T> comparator)
<V extends java.lang.Comparable<? super V>> MutableSortedSet<T>	toSortedSetBy(Function<? super T,? extends V> function)

Method Detail

asUnique

ParallelIterable<T> asUnique()

select

ParallelIterable<T> select(Predicate<? super T> predicate)

Creates a parallel iterable for selecting elements from the current iterable.

selectWith

<P> ParallelIterable<T> selectWith(Predicate2<? super T,? super P> predicate,
                                 P parameter)

selectInstancesOf

<S> ParallelIterable<S> selectInstancesOf(java.lang.Class<S> clazz)

reject

ParallelIterable<T> reject(Predicate<? super T> predicate)

Creates a parallel iterable for rejecting elements from the current iterable.

rejectWith

<P> ParallelIterable<T> rejectWith(Predicate2<? super T,? super P> predicate,
                                 P parameter)

collect

<V> ParallelIterable<V> collect(Function<? super T,? extends V> function)

Creates a parallel iterable for collecting elements from the current iterable.

collectWith

<P,V> ParallelIterable<V> collectWith(Function2<? super T,? super P,? extends V> function,
                                    P parameter)

collectIf

<V> ParallelIterable<V> collectIf(Predicate<? super T> predicate,
                                Function<? super T,? extends V> function)

Creates a parallel iterable for selecting and collecting elements from the current iterable.

flatCollect

<V> ParallelIterable<V> flatCollect(Function<? super T,? extends java.lang.Iterable<V>> function)

Creates a parallel flattening iterable for the current iterable.

forEach

void forEach(Procedure<? super T> procedure)

forEachWith

<P> void forEachWith(Procedure2<? super T,? super P> procedure,
                   P parameter)

detect

T detect(Predicate<? super T> predicate)

detectWith

<P> T detectWith(Predicate2<? super T,? super P> predicate,
               P parameter)

detectIfNone

T detectIfNone(Predicate<? super T> predicate,
             Function0<? extends T> function)

detectWithIfNone

<P> T detectWithIfNone(Predicate2<? super T,? super P> predicate,
                     P parameter,
                     Function0<? extends T> function)

count

int count(Predicate<? super T> predicate)

countWith

<P> int countWith(Predicate2<? super T,? super P> predicate,
                P parameter)

anySatisfy

boolean anySatisfy(Predicate<? super T> predicate)

anySatisfyWith

<P> boolean anySatisfyWith(Predicate2<? super T,? super P> predicate,
                         P parameter)

allSatisfy

boolean allSatisfy(Predicate<? super T> predicate)

allSatisfyWith

<P> boolean allSatisfyWith(Predicate2<? super T,? super P> predicate,
                         P parameter)

noneSatisfy

boolean noneSatisfy(Predicate<? super T> predicate)

noneSatisfyWith

<P> boolean noneSatisfyWith(Predicate2<? super T,? super P> predicate,
                          P parameter)

toList

MutableList<T> toList()

toSortedList

MutableList<T> toSortedList()

toSortedList

MutableList<T> toSortedList(java.util.Comparator<? super T> comparator)

toSortedListBy

<V extends java.lang.Comparable<? super V>> MutableList<T> toSortedListBy(Function<? super T,? extends V> function)

toSet

MutableSet<T> toSet()

toSortedSet

MutableSortedSet<T> toSortedSet()

toSortedSet

MutableSortedSet<T> toSortedSet(java.util.Comparator<? super T> comparator)

toSortedSetBy

<V extends java.lang.Comparable<? super V>> MutableSortedSet<T> toSortedSetBy(Function<? super T,? extends V> function)

toBag

MutableBag<T> toBag()

toMap

<NK,NV> MutableMap<NK,NV> toMap(Function<? super T,? extends NK> keyFunction,
                              Function<? super T,? extends NV> valueFunction)

toSortedMap

<NK,NV> MutableSortedMap<NK,NV> toSortedMap(Function<? super T,? extends NK> keyFunction,
                                          Function<? super T,? extends NV> valueFunction)

toSortedMap

<NK,NV> MutableSortedMap<NK,NV> toSortedMap(java.util.Comparator<? super NK> comparator,
                                          Function<? super T,? extends NK> keyFunction,
                                          Function<? super T,? extends NV> valueFunction)

toArray

java.lang.Object[] toArray()

toArray

<T1> T1[] toArray(T1[] target)

min

T min(java.util.Comparator<? super T> comparator)

max

T max(java.util.Comparator<? super T> comparator)

min

T min()

max

T max()

minBy

<V extends java.lang.Comparable<? super V>> T minBy(Function<? super T,? extends V> function)

maxBy

<V extends java.lang.Comparable<? super V>> T maxBy(Function<? super T,? extends V> function)

sumOfInt

long sumOfInt(IntFunction<? super T> function)

sumOfFloat

double sumOfFloat(FloatFunction<? super T> function)

sumOfLong

long sumOfLong(LongFunction<? super T> function)

sumOfDouble

double sumOfDouble(DoubleFunction<? super T> function)

makeString

java.lang.String makeString()

makeString

java.lang.String makeString(java.lang.String separator)

makeString

java.lang.String makeString(java.lang.String start,
                          java.lang.String separator,
                          java.lang.String end)

appendString

void appendString(java.lang.Appendable appendable)

appendString

void appendString(java.lang.Appendable appendable,
                java.lang.String separator)

appendString

void appendString(java.lang.Appendable appendable,
                java.lang.String start,
                java.lang.String separator,
                java.lang.String end)

groupBy

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

groupByEach

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

groupByUniqueKey

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

aggregateInPlaceBy

<K,V> MapIterable<K,V> aggregateInPlaceBy(Function<? super T,? extends K> groupBy,
                                        Function0<? extends V> zeroValueFactory,
                                        Procedure2<? super V,? super T> mutatingAggregator)

aggregateBy

<K,V> MapIterable<K,V> aggregateBy(Function<? super T,? extends K> groupBy,
                                 Function0<? extends V> zeroValueFactory,
                                 Function2<? super V,? super T,? extends V> nonMutatingAggregator)