Class MultiReaderParallelIterable<T>
- java.lang.Object
-
- org.eclipse.collections.impl.lazy.parallel.AbstractMultiReaderParallelIterable<T,ParallelIterable<T>>
-
- org.eclipse.collections.impl.lazy.parallel.MultiReaderParallelIterable<T>
-
- All Implemented Interfaces:
ParallelIterable<T>
public final class MultiReaderParallelIterable<T> extends AbstractMultiReaderParallelIterable<T,ParallelIterable<T>>
-
-
Field Summary
-
Fields inherited from class org.eclipse.collections.impl.lazy.parallel.AbstractMultiReaderParallelIterable
delegate, lock
-
-
Constructor Summary
Constructors Constructor Description MultiReaderParallelIterable(ParallelIterable<T> delegate, java.util.concurrent.locks.ReadWriteLock lock)
-
Method Summary
All Methods Instance Methods Concrete Methods 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 java.lang.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 java.lang.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(java.lang.Class<S> clazz)
<P> ParallelIterable<T>
selectWith(Predicate2<? super T,? super P> predicate, P parameter)
-
Methods inherited from class org.eclipse.collections.impl.lazy.parallel.AbstractMultiReaderParallelIterable
aggregateBy, aggregateInPlaceBy, allSatisfy, allSatisfyWith, anySatisfy, anySatisfyWith, appendString, appendString, appendString, count, countWith, detect, detectIfNone, detectWith, detectWithIfNone, forEach, forEachWith, groupByUniqueKey, makeString, 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
-
-
-
-
Constructor Detail
-
MultiReaderParallelIterable
public MultiReaderParallelIterable(ParallelIterable<T> delegate, java.util.concurrent.locks.ReadWriteLock lock)
-
-
Method Detail
-
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(java.lang.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 java.lang.Iterable<V>> function)
Description copied from interface:ParallelIterable
Creates a parallel flattening iterable for the current iterable.
-
-