Top Inners Fields Constructors Methods
org.eclipse.collections.impl.lazy.parallel.list

public final Class ListIterableParallelIterable<T>

extends AbstractParallelListIterable<T, RootListBatch<T>>
Class Inheritance
Annotations
@Beta
Imports
java.util.Iterator, .RandomAccess, java.util.concurrent.ExecutorService, org.eclipse.collections.api.LazyIterable, org.eclipse.collections.api.annotation.Beta, org.eclipse.collections.api.block.function.Function, org.eclipse.collections.api.block.predicate.Predicate, org.eclipse.collections.api.block.procedure.Procedure, org.eclipse.collections.api.list.ListIterable, org.eclipse.collections.api.map.MapIterable, org.eclipse.collections.api.multimap.list.ListMultimap, org.eclipse.collections.impl.lazy.AbstractLazyIterable, org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
private class

Field Summary

Modifier and TypeField and Description
private final int
private final ListIterable<T>
private final ExecutorService

Constructor Summary

AccessConstructor and Description
public
ListIterableParallelIterable(ListIterable<T> delegate, ExecutorService executorService, int batchSize)

Method Summary

Modifier and TypeMethod and Description
public boolean
public boolean
public T
public void
public int
public ExecutorService
public <V> ListMultimap<V, T>
public <V> ListMultimap<V, T>
public <V> MapIterable<V, T>
public LazyIterable<RootListBatch<T>>
public Object[]
public <E> E[]
Inherited from org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable:
asUniquecollectcollectIfcollectWithflatCollectisOrderedrejectrejectWithselectselectInstancesOfselectWith

Field Detail

batchSizeback to summary
private final int batchSize
delegateback to summary
private final ListIterable<T> delegate
executorServiceback to summary
private final ExecutorService executorService

Constructor Detail

ListIterableParallelIterableback to summary
public ListIterableParallelIterable(ListIterable<T> delegate, ExecutorService executorService, int batchSize)

Method Detail

allSatisfyback to summary
public boolean allSatisfy(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.allSatisfy.

Annotations
@Override
anySatisfyback to summary
public boolean anySatisfy(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.anySatisfy.

Annotations
@Override
detectback to summary
public T detect(Predicate<? super T> predicate)

Implements org.eclipse.collections.api.ParallelIterable.detect.

Annotations
@Override
forEachback to summary
public void forEach(Procedure<? super T> procedure)

Implements org.eclipse.collections.api.ParallelIterable.forEach.

Annotations
@Override
getBatchSizeback to summary
public int getBatchSize()

Implements abstract org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable.getBatchSize.

Annotations
@Override
getExecutorServiceback to summary
public ExecutorService getExecutorService()

Implements abstract org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable.getExecutorService.

Annotations
@Override
groupByback to summary
public <V> ListMultimap<V, T> groupBy(Function<? super T, ? extends V> function)

Overrides org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable.groupBy.

Implements org.eclipse.collections.api.list.ParallelListIterable.groupBy, org.eclipse.collections.api.ParallelIterable.groupBy.

Annotations
@Override
groupByEachback to summary
public <V> ListMultimap<V, T> groupByEach(Function<? super T, ? extends Iterable<V>> function)

Overrides org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable.groupByEach.

Implements org.eclipse.collections.api.list.ParallelListIterable.groupByEach, org.eclipse.collections.api.ParallelIterable.groupByEach.

Annotations
@Override
groupByUniqueKeyback to summary
public <V> MapIterable<V, T> groupByUniqueKey(Function<? super T, ? extends V> function)

Overrides org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable.groupByUniqueKey.

Implements org.eclipse.collections.api.ParallelIterable.groupByUniqueKey.

Annotations
@Override
splitback to summary
public LazyIterable<RootListBatch<T>> split()

Implements abstract org.eclipse.collections.impl.lazy.parallel.AbstractParallelIterable.split.

Annotations
@Override
toArrayback to summary
public Object[] toArray()

Overrides org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable.toArray.

Overrides default org.eclipse.collections.api.ParallelIterable.toArray.

Annotations
@Override
toArrayback to summary
public <E> E[] toArray(E[] array)

Overrides org.eclipse.collections.impl.lazy.parallel.list.AbstractParallelListIterable.toArray.

Implements org.eclipse.collections.api.ParallelIterable.toArray.

Annotations
@Override
org.eclipse.collections.impl.lazy.parallel.list back to summary

private Class ListIterableParallelIterable.ListIterableParallelBatchIterator

extends Object
implements Iterator<RootListBatch<T>>
Class Inheritance
  • java.lang.Object
  • org.eclipse.collections.impl.lazy.parallel.list.ListIterableParallelIterable.ListIterableParallelBatchIterator
All Implemented Interfaces
java.util.Iterator

Field Summary

Modifier and TypeField and Description
protected int

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public boolean
hasNext()

Implements java.util.Iterator.hasNext.

Returns true if the iteration has more elements.

public RootListBatch<T>
next()

Implements java.util.Iterator.next.

Returns the next element in the iteration.

public void
remove()

Overrides default java.util.Iterator.remove.

Removes from the underlying collection the last element returned by this iterator (optional operation).

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

chunkIndexback to summary
protected int chunkIndex

Constructor Detail

ListIterableParallelBatchIteratorback to summary
private ListIterableParallelBatchIterator()

Method Detail

hasNextback to summary
public boolean hasNext()

Implements java.util.Iterator.hasNext.

Doc from java.util.Iterator.hasNext.

Returns true if the iteration has more elements. (In other words, returns true if next would return an element rather than throwing an exception.)

Annotations
@Override
nextback to summary
public RootListBatch<T> next()

Implements java.util.Iterator.next.

Doc from java.util.Iterator.next.

Returns the next element in the iteration.

Annotations
@Override
removeback to summary
public void remove()

Overrides default java.util.Iterator.remove.

Doc from java.util.Iterator.remove.

Removes from the underlying collection the last element returned by this iterator (optional operation). This method can be called only once per call to next.

The behavior of an iterator is unspecified if the underlying collection is modified while the iteration is in progress in any way other than by calling this method, unless an overriding class has specified a concurrent modification policy.

The behavior of an iterator is unspecified if this method is called after a call to the forEachRemaining method.

Annotations
@Override
org.eclipse.collections.impl.lazy.parallel.list back to summary

private Class ListIterableParallelIterable.ListIterableParallelBatchLazyIterable

extends AbstractLazyIterable<RootListBatch<T>>
Class Inheritance

Constructor Summary

AccessConstructor and Description
private

Method Summary

Modifier and TypeMethod and Description
public void
each(Procedure<? super RootListBatch<T>> procedure)

Implements org.eclipse.collections.api.RichIterable.each.

The procedure is executed for each element in the iterable.

public Iterator<RootListBatch<T>>
iterator()

Implements java.lang.Iterable.iterator.

Returns an iterator over elements of type T.

Inherited from org.eclipse.collections.impl.lazy.AbstractLazyIterable:
asLazychunkcollectcollectBooleancollectBytecollectCharcollectDoublecollectFloatcollectIfcollectIntcollectLongcollectShortcollectWithconcatenatedistinctdropdropWhileflatCollectgetFirstgetLastgetOnlygroupBygroupByEachgroupByUniqueKeyintoisEmptymaxByOptionalmaxOptionalmaxOptionalminByOptionalminOptionalminOptionalpartitionpartitionWithrejectrejectWithselectselectInstancesOfselectWithsizesumByDoublesumByFloatsumByIntsumByLongtaketakeWhiletaptoStackzipzipWithIndex

Constructor Detail

ListIterableParallelBatchLazyIterableback to summary
private ListIterableParallelBatchLazyIterable()

Method Detail

eachback to summary
public void each(Procedure<? super RootListBatch<T>> procedure)

Implements org.eclipse.collections.api.RichIterable.each.

Doc from org.eclipse.collections.api.RichIterable.each.

The procedure is executed for each element in the iterable.

Example using a Java 8 lambda expression:

people.each(person -> LOGGER.info(person.getName()));
This method is a variant of InternalIterable#forEach(Procedure) that has a signature conflict with Iterable#forEach(java.util.function.Consumer).
Annotations
@Override
iteratorback to summary
public Iterator<RootListBatch<T>> iterator()

Implements java.lang.Iterable.iterator.

Doc from java.lang.Iterable.iterator.

Returns an iterator over elements of type T.

Annotations
@Override