Package org.eclipse.collections.api

Interface ParallelIterable<T>

All Known Subinterfaces:
ParallelBag<T>, ParallelListIterable<T>, ParallelSetIterable<T>, ParallelSortedBag<T>, ParallelSortedSetIterable<T>, ParallelUnsortedBag<T>, ParallelUnsortedSetIterable<T>
All Known Implementing Classes:
AbstractMultiReaderParallelIterable, AbstractParallelIterable, AbstractParallelIterableImpl, AbstractParallelListIterable, AbstractParallelSortedSetIterable, AbstractParallelUnsortedBag, AbstractParallelUnsortedSetIterable, AbstractSynchronizedParallelIterable, ListIterableParallelIterable, MultiReaderParallelIterable, MultiReaderParallelListIterable, MultiReaderParallelUnsortedSetIterable, NonParallelIterable, NonParallelListIterable, NonParallelSortedSetIterable, NonParallelUnsortedBag, NonParallelUnsortedSetIterable, ParallelCollectIterable, ParallelCollectListIterable, ParallelCollectUnsortedBag, ParallelDistinctIterable, ParallelFlatCollectIterable, ParallelFlatCollectListIterable, ParallelSelectIterable, SynchronizedParallelIterable, SynchronizedParallelListIterable, SynchronizedParallelSortedSetIterable, SynchronizedParallelUnsortedSetIterable
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 Details

    • 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(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 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

      default MutableList<T> toSortedList()

    • toSortedList

      MutableList<T> toSortedList(Comparator<? super T> comparator)

    • toSortedListBy

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

    • toSet

      MutableSet<T> toSet()

    • toSortedSet

      MutableSortedSet<T> toSortedSet()

    • toSortedSet

      MutableSortedSet<T> toSortedSet(Comparator<? super T> comparator)

    • toSortedSetBy

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

    • toBag

      MutableBag<T> toBag()

    • toSortedBag

      MutableSortedBag<T> toSortedBag()

    • toSortedBag

      MutableSortedBag<T> toSortedBag(Comparator<? super T> comparator)

    • toSortedBagBy

      <V extends Comparable<? super V>> MutableSortedBag<T> toSortedBagBy(Function<? super T,? extends V> function)

    • 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(Comparator<? super NK> comparator, Function<? super T,? extends NK> keyFunction, Function<? super T,? extends NV> valueFunction)

    • toArray

      default Object[] toArray()

    • toArray

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

    • min

      T min(Comparator<? super T> comparator)

    • max

      T max(Comparator<? super T> comparator)

    • min

      T min()

    • max

      T max()

    • minBy

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

    • maxBy

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

    • sumOfInt

      long sumOfInt(IntFunction<? super T> function)
      Returns the final long result of evaluating function for each element of the iterable in parallel and adding the results together.
      Since:
      6.0

    • sumOfFloat

      double sumOfFloat(FloatFunction<? super T> function)
      Returns the final double result of evaluating function for each element of the iterable in parallel and adding the results together. It uses Kahan summation algorithm to reduce numerical error.
      Since:
      6.0

    • sumOfLong

      long sumOfLong(LongFunction<? super T> function)
      Returns the final long result of evaluating function for each element of the iterable in parallel and adding the results together.
      Since:
      6.0

    • sumOfDouble

      double sumOfDouble(DoubleFunction<? super T> function)
      Returns the final double result of evaluating function for each element of the iterable in parallel and adding the results together. It uses Kahan summation algorithm to reduce numerical error.
      Since:
      6.0

    • makeString

      default String makeString()

    • makeString

      default String makeString(String separator)

    • makeString

      default String makeString(String start, String separator, String end)

    • appendString

      default void appendString(Appendable appendable)

    • appendString

      default void appendString(Appendable appendable, String separator)

    • appendString

      void appendString(Appendable appendable, String start, String separator, String end)

    • groupBy

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

    • groupByEach

      <V> Multimap<V,T> groupByEach(Function<? super T,? extends 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)