Class SynchronizedParallelIterable<T>

java.lang.Object

org.eclipse.collections.impl.lazy.parallel.AbstractSynchronizedParallelIterable<T, ParallelIterable<T>>

org.eclipse.collections.impl.lazy.parallel.SynchronizedParallelIterable<T>

All Implemented Interfaces:

ParallelIterable<T>

public final class SynchronizedParallelIterable<T>
extends AbstractSynchronizedParallelIterable<T, ParallelIterable<T>>

Field Summary

Fields inherited from class AbstractSynchronizedParallelIterable

delegate, lock

Constructor Summary

Constructors

Constructor	Description
SynchronizedParallelIterable(ParallelIterable<T> delegate, Object lock)

Method Summary

Modifier and Type	Method	Description
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)
<V> ParallelIterable<V>	flatCollect(Function<? super T, ? extends Iterable<V>> function)	Creates a parallel flattening iterable for the current iterable.
<V> Multimap<V,T>	groupBy(Function<? super T, ? extends V> function)
<V> Multimap<V,T>	groupByEach(Function<? super T, ? extends Iterable<V>> function)
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(Class<S> clazz)
<P> ParallelIterable<T>	selectWith(Predicate2<? super T, ? super P> predicate, P parameter)

Methods inherited from class AbstractSynchronizedParallelIterable

aggregateBy, aggregateInPlaceBy, allSatisfy, allSatisfyWith, anySatisfy, anySatisfyWith, appendString, appendString, appendString, count, countWith, detect, detectIfNone, detectWith, detectWithIfNone, forEach, forEachWith, groupByUniqueKey, makeString, makeString, makeString, max, max, maxBy, min, min, minBy, noneSatisfy, noneSatisfyWith, sumOfDouble, sumOfFloat, sumOfInt, sumOfLong, toArray, toArray, toBag, toList, toMap, toSet, toSortedBag, toSortedBag, toSortedBagBy, toSortedList, toSortedList, toSortedListBy, toSortedMap, toSortedMap, toSortedSet, toSortedSet, toSortedSetBy, toString, wrap, wrap, wrap, wrap

Methods inherited from class Object

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

Methods inherited from interface ParallelIterable

makeString

Constructor Details

SynchronizedParallelIterable

public SynchronizedParallelIterable(ParallelIterable<T> delegate,
 Object lock)

Method Details

asUnique

public ParallelIterable<T> asUnique()

select

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

Description copied from interface: ParallelIterable

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

selectWith

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

reject

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

Description copied from interface: ParallelIterable

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

rejectWith

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

selectInstancesOf

public <S> ParallelIterable<S> selectInstancesOf(Class<S> clazz)

collect

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

Description copied from interface: ParallelIterable

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

collectWith

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

collectIf

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

Description copied from interface: ParallelIterable

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

flatCollect

public <V> ParallelIterable<V> flatCollect(Function<? super T, ? extends Iterable<V>> function)

Description copied from interface: ParallelIterable

Creates a parallel flattening iterable for the current iterable.

groupBy

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

groupByEach

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