|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.util.concurrent.jdk8backported.ConcurrentHashMapV8.ForkJoinTasks
public static class ConcurrentHashMapV8.ForkJoinTasks
Predefined tasks for performing bulk parallel operations on
ConcurrentHashMaps. These tasks follow the forms and rules used
in class ConcurrentHashMapV8.Parallel
. Each method has the same name, but
returns a task rather than invoking it. These methods may be
useful in custom applications such as submitting a task without
waiting for completion, or combining with other tasks.
Method Summary | ||
---|---|---|
static
|
forEach(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiAction<K,V> action)
Returns a task that when invoked, performs the given action for each (key, value) |
|
static
|
forEach(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer,
ConcurrentHashMapV8.Action<U> action)
Returns a task that when invoked, performs the given action for each non-null transformation of each (key, value) |
|
static
|
forEachEntry(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Action<Map.Entry<K,V>> action)
Returns a task that when invoked, perform the given action for each entry. |
|
static
|
forEachEntry(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<Map.Entry<K,V>,? extends U> transformer,
ConcurrentHashMapV8.Action<U> action)
Returns a task that when invoked, perform the given action for each non-null transformation of each entry. |
|
static
|
forEachKey(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Action<K> action)
Returns a task that when invoked, performs the given action for each key. |
|
static
|
forEachKey(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<? super K,? extends U> transformer,
ConcurrentHashMapV8.Action<U> action)
Returns a task that when invoked, performs the given action for each non-null transformation of each key. |
|
static
|
forEachValue(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Action<V> action)
Returns a task that when invoked, performs the given action for each value. |
|
static
|
forEachValue(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<? super V,? extends U> transformer,
ConcurrentHashMapV8.Action<U> action)
Returns a task that when invoked, performs the given action for each non-null transformation of each value. |
|
static
|
reduce(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer,
ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all (key, value) pairs using the given reducer to combine values, or null if none. |
|
static
|
reduceEntries(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiFun<Map.Entry<K,V>,Map.Entry<K,V>,? extends Map.Entry<K,V>> reducer)
Returns a task that when invoked, returns the result of accumulating all entries using the given reducer to combine values, or null if none. |
|
static
|
reduceEntries(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<Map.Entry<K,V>,? extends U> transformer,
ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all entries using the given reducer to combine values, or null if none. |
|
static
|
reduceEntriesToDouble(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToDouble<Map.Entry<K,V>> transformer,
double basis,
ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all entries using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceEntriesToInt(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToInt<Map.Entry<K,V>> transformer,
int basis,
ConcurrentHashMapV8.IntByIntToInt reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all entries using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceEntriesToLong(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToLong<Map.Entry<K,V>> transformer,
long basis,
ConcurrentHashMapV8.LongByLongToLong reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all entries using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceKeys(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiFun<? super K,? super K,? extends K> reducer)
Returns a task that when invoked, returns the result of accumulating all keys using the given reducer to combine values, or null if none. |
|
static
|
reduceKeys(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<? super K,? extends U> transformer,
ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all keys using the given reducer to combine values, or null if none. |
|
static
|
reduceKeysToDouble(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToDouble<? super K> transformer,
double basis,
ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all keys using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceKeysToInt(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToInt<? super K> transformer,
int basis,
ConcurrentHashMapV8.IntByIntToInt reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all keys using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceKeysToLong(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToLong<? super K> transformer,
long basis,
ConcurrentHashMapV8.LongByLongToLong reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all keys using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceToDouble(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectByObjectToDouble<? super K,? super V> transformer,
double basis,
ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all (key, value) pairs using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceToInt(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectByObjectToInt<? super K,? super V> transformer,
int basis,
ConcurrentHashMapV8.IntByIntToInt reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all (key, value) pairs using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceToLong(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectByObjectToLong<? super K,? super V> transformer,
long basis,
ConcurrentHashMapV8.LongByLongToLong reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all (key, value) pairs using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceValues(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiFun<? super V,? super V,? extends V> reducer)
Returns a task that when invoked, returns the result of accumulating all values using the given reducer to combine values, or null if none. |
|
static
|
reduceValues(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<? super V,? extends U> transformer,
ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all values using the given reducer to combine values, or null if none. |
|
static
|
reduceValuesToDouble(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToDouble<? super V> transformer,
double basis,
ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all values using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceValuesToInt(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToInt<? super V> transformer,
int basis,
ConcurrentHashMapV8.IntByIntToInt reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all values using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
reduceValuesToLong(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.ObjectToLong<? super V> transformer,
long basis,
ConcurrentHashMapV8.LongByLongToLong reducer)
Returns a task that when invoked, returns the result of accumulating the given transformation of all values using the given reducer to combine values, and the given basis as an identity value. |
|
static
|
search(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> searchFunction)
Returns a task that when invoked, returns a non-null result from applying the given search function on each (key, value), or null if none. |
|
static
|
searchEntries(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<Map.Entry<K,V>,? extends U> searchFunction)
Returns a task that when invoked, returns a non-null result from applying the given search function on each entry, or null if none. |
|
static
|
searchKeys(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<? super K,? extends U> searchFunction)
Returns a task that when invoked, returns a non-null result from applying the given search function on each key, or null if none. |
|
static
|
searchValues(ConcurrentHashMapV8<K,V> map,
ConcurrentHashMapV8.Fun<? super V,? extends U> searchFunction)
Returns a task that when invoked, returns a non-null result from applying the given search function on each value, or null if none. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public static <K,V> ForkJoinTask<Void> forEach(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiAction<K,V> action)
map
- the mapaction
- the action
public static <K,V,U> ForkJoinTask<Void> forEach(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer, ConcurrentHashMapV8.Action<U> action)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case the action is not applied).action
- the action
public static <K,V,U> ForkJoinTask<U> search(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> searchFunction)
map
- the mapsearchFunction
- a function returning a non-null
result on success, else null
public static <K,V,U> ForkJoinTask<U> reduce(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiFun<? super K,? super V,? extends U> transformer, ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case it is not combined).reducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Double> reduceToDouble(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectByObjectToDouble<? super K,? super V> transformer, double basis, ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Long> reduceToLong(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectByObjectToLong<? super K,? super V> transformer, long basis, ConcurrentHashMapV8.LongByLongToLong reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Integer> reduceToInt(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectByObjectToInt<? super K,? super V> transformer, int basis, ConcurrentHashMapV8.IntByIntToInt reducer)
transformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Void> forEachKey(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Action<K> action)
map
- the mapaction
- the action
public static <K,V,U> ForkJoinTask<Void> forEachKey(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<? super K,? extends U> transformer, ConcurrentHashMapV8.Action<U> action)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case the action is not applied).action
- the action
public static <K,V,U> ForkJoinTask<U> searchKeys(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<? super K,? extends U> searchFunction)
map
- the mapsearchFunction
- a function returning a non-null
result on success, else null
public static <K,V> ForkJoinTask<K> reduceKeys(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiFun<? super K,? super K,? extends K> reducer)
map
- the mapreducer
- a commutative associative combining function
public static <K,V,U> ForkJoinTask<U> reduceKeys(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<? super K,? extends U> transformer, ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case it is not combined).reducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Double> reduceKeysToDouble(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToDouble<? super K> transformer, double basis, ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Long> reduceKeysToLong(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToLong<? super K> transformer, long basis, ConcurrentHashMapV8.LongByLongToLong reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Integer> reduceKeysToInt(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToInt<? super K> transformer, int basis, ConcurrentHashMapV8.IntByIntToInt reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Void> forEachValue(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Action<V> action)
map
- the mapaction
- the actionpublic static <K,V,U> ForkJoinTask<Void> forEachValue(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<? super V,? extends U> transformer, ConcurrentHashMapV8.Action<U> action)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case the action is not applied).action
- the actionpublic static <K,V,U> ForkJoinTask<U> searchValues(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<? super V,? extends U> searchFunction)
map
- the mapsearchFunction
- a function returning a non-null
result on success, else null
public static <K,V> ForkJoinTask<V> reduceValues(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiFun<? super V,? super V,? extends V> reducer)
map
- the mapreducer
- a commutative associative combining function
public static <K,V,U> ForkJoinTask<U> reduceValues(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<? super V,? extends U> transformer, ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case it is not combined).reducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Double> reduceValuesToDouble(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToDouble<? super V> transformer, double basis, ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Long> reduceValuesToLong(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToLong<? super V> transformer, long basis, ConcurrentHashMapV8.LongByLongToLong reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Integer> reduceValuesToInt(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToInt<? super V> transformer, int basis, ConcurrentHashMapV8.IntByIntToInt reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Void> forEachEntry(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Action<Map.Entry<K,V>> action)
map
- the mapaction
- the actionpublic static <K,V,U> ForkJoinTask<Void> forEachEntry(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<Map.Entry<K,V>,? extends U> transformer, ConcurrentHashMapV8.Action<U> action)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case the action is not applied).action
- the actionpublic static <K,V,U> ForkJoinTask<U> searchEntries(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<Map.Entry<K,V>,? extends U> searchFunction)
map
- the mapsearchFunction
- a function returning a non-null
result on success, else null
public static <K,V> ForkJoinTask<Map.Entry<K,V>> reduceEntries(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.BiFun<Map.Entry<K,V>,Map.Entry<K,V>,? extends Map.Entry<K,V>> reducer)
map
- the mapreducer
- a commutative associative combining function
public static <K,V,U> ForkJoinTask<U> reduceEntries(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Fun<Map.Entry<K,V>,? extends U> transformer, ConcurrentHashMapV8.BiFun<? super U,? super U,? extends U> reducer)
map
- the maptransformer
- a function returning the transformation
for an element, or null of there is no transformation (in
which case it is not combined).reducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Double> reduceEntriesToDouble(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToDouble<Map.Entry<K,V>> transformer, double basis, ConcurrentHashMapV8.DoubleByDoubleToDouble reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Long> reduceEntriesToLong(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToLong<Map.Entry<K,V>> transformer, long basis, ConcurrentHashMapV8.LongByLongToLong reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
public static <K,V> ForkJoinTask<Integer> reduceEntriesToInt(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.ObjectToInt<Map.Entry<K,V>> transformer, int basis, ConcurrentHashMapV8.IntByIntToInt reducer)
map
- the maptransformer
- a function returning the transformation
for an elementbasis
- the identity (initial default value) for the reductionreducer
- a commutative associative combining function
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |