Package | Description |
---|---|
groovyx.gpars |
This package holds classes for asynchronous collection processing.
|
groovyx.gpars.extra166y |
Collections supporting parallel operations.
|
Modifier and Type | Method and Description |
---|---|
private static <K,V> ParallelArray<java.util.Map.Entry<K,V>> |
GParsPoolUtil.createPA(java.util.Map<K,V> collection,
jsr166y.ForkJoinPool pool) |
static <T> ParallelArray<T> |
GParsPoolUtil.getParallelArray(java.util.Collection<T> collection)
Creates a ParallelArray wrapping the elements of the original collection.
|
static ParallelArray |
GParsPoolUtil.getParallelArray(java.lang.Object collection)
Creates a ParallelArray wrapping the elements of the original collection.
|
Modifier and Type | Method and Description |
---|---|
private static <K,T> java.util.Map<K,java.util.List<T>> |
GParsPoolUtil.groupByParallelPA(ParallelArray<T> pa,
groovy.lang.Closure<K> cl) |
Modifier and Type | Method and Description |
---|---|
<V> ParallelArray<T> |
ParallelArray.addAll(ParallelArrayWithMapping<V,T> other)
Appends all (possibly bounded, filtered, or mapped) elements of
the given ParallelArray, resizing and/or reallocating this
array if necessary.
|
ParallelArray<T> |
ParallelArray.addAll(T[] other)
Equivalent to
asList().addAll but specialized for array
arguments and likely to be more efficient. |
ParallelArray<T> |
ParallelArray.all()
Returns a new ParallelArray holding all elements.
|
ParallelArray<U> |
ParallelArrayWithMapping.all()
Returns a new ParallelArray holding elements.
|
ParallelArray<U> |
ParallelDoubleArrayWithMapping.all()
Returns a new ParallelArray holding elements.
|
ParallelArray<U> |
ParallelLongArrayWithMapping.all()
Returns a new ParallelArray holding mapped elements.
|
ParallelArray<T> |
ParallelArray.all(java.lang.Class<? super T> elementType)
Returns a new ParallelArray with the given element type holding
all elements.
|
ParallelArray<U> |
AbstractParallelAnyArray.DFOMPap.all(java.lang.Class<? super U> elementType) |
ParallelArray<U> |
AbstractParallelAnyArray.DROMPap.all(java.lang.Class<? super U> elementType) |
ParallelArray<U> |
ParallelArrayWithMapping.all(java.lang.Class<? super U> elementType)
Returns a new ParallelArray with the given element type
holding elements.
|
ParallelArray<U> |
ParallelDoubleArrayWithMapping.all(java.lang.Class<? super U> elementType)
Returns a new ParallelArray with the given element type holding
elements.
|
ParallelArray<U> |
ParallelLongArrayWithMapping.all(java.lang.Class<? super U> elementType)
Returns a new ParallelArray with the given element type holding
all elements.
|
ParallelArray<T> |
ParallelArray.allNonidenticalElements()
Returns a new ParallelArray containing only the non-null unique
elements of this array (that is, without any duplicates), using
reference identity to test for duplication.
|
ParallelArray<T> |
ParallelArrayWithFilter.allNonidenticalElements()
Returns a new ParallelArray containing only non-null unique
elements (that is, without any duplicates).
|
ParallelArray<T> |
ParallelArray.allUniqueElements()
Returns a new ParallelArray containing only the non-null unique
elements of this array (that is, without any duplicates), using
each element's
equals method to test for duplication. |
ParallelArray<T> |
ParallelArrayWithFilter.allUniqueElements()
Returns a new ParallelArray containing only non-null unique
elements (that is, without any duplicates).
|
static <T> ParallelArray<T> |
ParallelArray.create(int size,
java.lang.Class<? super T> elementType,
jsr166y.ForkJoinPool executor)
Creates a new ParallelArray using the given executor and
an array of the given size constructed using the
indicated base element type.
|
static <T> ParallelArray<T> |
ParallelArray.createEmpty(int size,
java.lang.Class<? super T> elementType,
jsr166y.ForkJoinPool executor)
Creates a new ParallelArray using the given executor and an
array of the given size constructed using the indicated base
element type, but with an initial effective size of zero,
enabling incremental insertion via
asList()
operations. |
static <T> ParallelArray<T> |
ParallelArray.createFromCopy(int size,
T[] source,
jsr166y.ForkJoinPool executor)
Creates a new ParallelArray using an array of the given size,
initially holding copies of the given source truncated or
padded with nulls to obtain the specified length.
|
static <T> ParallelArray<T> |
ParallelArray.createFromCopy(T[] source,
jsr166y.ForkJoinPool executor)
Creates a new ParallelArray using the given executor and
initially holding copies of the given
source elements.
|
static <T> ParallelArray<T> |
ParallelArray.createUsingHandoff(T[] handoff,
jsr166y.ForkJoinPool executor)
Creates a new ParallelArray initially using the given array and
executor.
|
ParallelArray<T> |
ParallelArray.cumulate(Ops.Reducer<T> reducer,
T base)
Replaces each element with the running cumulation of applying
the given reducer.
|
ParallelArray<T> |
ParallelArray.removeAll(Ops.Predicate<? super T> selector)
Removes from the array all elements for which the given
selector holds.
|
ParallelArray<T> |
ParallelArray.removeConsecutiveDuplicates()
Removes consecutive elements that are equal (or null),
shifting others leftward, and possibly decreasing size.
|
ParallelArray<T> |
ParallelArray.removeNulls()
Removes null elements, shifting others leftward, and possibly
decreasing size.
|
ParallelArray<T> |
ParallelArray.replaceWithGeneratedValue(Ops.Generator<? extends T> generator)
Replaces elements with the results of applying the given
generator.
|
ParallelArray<T> |
ParallelArray.replaceWithMappedIndex(Ops.IntAndObjectToObject<? super T,? extends T> op)
Replaces elements with the results of applying the given
mapping to each index and current element value.
|
ParallelArray<T> |
ParallelArray.replaceWithMappedIndex(Ops.IntToObject<? extends T> op)
Replaces elements with the results of applying the given
mapping to their indices.
|
<V,W> ParallelArray<T> |
ParallelArray.replaceWithMapping(Ops.BinaryOp<? super T,? super V,? extends T> combiner,
ParallelArrayWithMapping<W,V> other)
Replaces elements with results of applying
op(thisElement, otherElement) . |
ParallelArray<T> |
ParallelArray.replaceWithMapping(Ops.BinaryOp<T,T,T> combiner,
T[] other)
Replaces elements with results of applying
op(thisElement, otherElement) . |
ParallelArray<T> |
ParallelArray.replaceWithMapping(Ops.Op<? super T,? extends T> op)
Replaces elements with the results of applying the given transform
to their current values.
|
ParallelArray<T> |
ParallelArray.replaceWithValue(T value)
Replaces elements with the given value.
|
ParallelArray<T> |
ParallelArray.sort()
Sorts the array, assuming all elements are Comparable.
|
ParallelArray<T> |
ParallelArray.sort(java.util.Comparator<? super T> comparator)
Sorts the array.
|