Infinispan Distribution 5.2.6.Final-redhat-2

Uses of Class
org.infinispan.util.concurrent.jdk8backported.ForkJoinTask

Packages that use ForkJoinTask
org.infinispan.util.concurrent.jdk8backported   
 

Uses of ForkJoinTask in org.infinispan.util.concurrent.jdk8backported
 

Methods in org.infinispan.util.concurrent.jdk8backported with type parameters of type ForkJoinTask
static
<T extends ForkJoinTask<?>>
Collection<T>
ForkJoinTask.invokeAll(Collection<T> tasks)
          Forks all tasks in the specified collection, returning when isDone holds for each task or an (unchecked) exception is encountered, in which case the exception is rethrown.
 

Methods in org.infinispan.util.concurrent.jdk8backported that return ForkJoinTask
static
<T> ForkJoinTask<T>
ForkJoinTask.adapt(Callable<? extends T> callable)
          Returns a new ForkJoinTask that performs the call method of the given Callable as its action, and returns its result upon join(), translating any checked exceptions encountered into RuntimeException.
static ForkJoinTask<?> ForkJoinTask.adapt(Runnable runnable)
          Returns a new ForkJoinTask that performs the run method of the given Runnable as its action, and returns a null result upon join().
static
<T> ForkJoinTask<T>
ForkJoinTask.adapt(Runnable runnable, T result)
          Returns a new ForkJoinTask that performs the run method of the given Runnable as its action, and returns the given result upon join().
static
<K,V> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.forEachKey(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Action<K> action)
          Returns a task that when invoked, performs the given action for each key.
static
<K,V,U> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.forEachValue(ConcurrentHashMapV8<K,V> map, ConcurrentHashMapV8.Action<V> action)
          Returns a task that when invoked, performs the given action for each value.
static
<K,V,U> ForkJoinTask<Void>
ConcurrentHashMapV8.ForkJoinTasks.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.
 ForkJoinTask<V> ForkJoinTask.fork()
          Arranges to asynchronously execute this task.
protected static ForkJoinTask<?> ForkJoinTask.peekNextLocalTask()
          Returns, but does not unschedule or execute, a task queued by the current thread but not yet executed, if one is immediately available.
protected static ForkJoinTask<?> ForkJoinTask.pollNextLocalTask()
          Unschedules and returns, without executing, the next task queued by the current thread but not yet executed.
protected  ForkJoinTask<?> ForkJoinPool.pollSubmission()
          Removes and returns the next unexecuted submission if one is available.
protected static ForkJoinTask<?> ForkJoinTask.pollTask()
          Unschedules and returns, without executing, the next task queued by the current thread but not yet executed, if one is available, or if not available, a task that was forked by some other thread, if available.
static
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Map.Entry<K,V>>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Double>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Integer>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Long>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<K>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Double>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Integer>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Long>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Double>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Integer>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Long>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<V>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Double>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Integer>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V> ForkJoinTask<Long>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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
<K,V,U> ForkJoinTask<U>
ConcurrentHashMapV8.ForkJoinTasks.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.
<T> ForkJoinTask<T>
ForkJoinPool.submit(Callable<T> task)
           
<T> ForkJoinTask<T>
ForkJoinPool.submit(ForkJoinTask<T> task)
          Submits a ForkJoinTask for execution.
 ForkJoinTask<?> ForkJoinPool.submit(Runnable task)
           
<T> ForkJoinTask<T>
ForkJoinPool.submit(Runnable task, T result)
           
 

Methods in org.infinispan.util.concurrent.jdk8backported with parameters of type ForkJoinTask
 void ForkJoinPool.execute(ForkJoinTask<?> task)
          Arranges for (asynchronous) execution of the given task.
<T> T
ForkJoinPool.invoke(ForkJoinTask<T> task)
          Performs the given task, returning its result upon completion.
static void ForkJoinTask.invokeAll(ForkJoinTask<?>... tasks)
          Forks the given tasks, returning when isDone holds for each task or an (unchecked) exception is encountered, in which case the exception is rethrown.
static void ForkJoinTask.invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2)
          Forks the given tasks, returning when isDone holds for each task or an (unchecked) exception is encountered, in which case the exception is rethrown.
static void ForkJoinTask.invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2)
          Forks the given tasks, returning when isDone holds for each task or an (unchecked) exception is encountered, in which case the exception is rethrown.
<T> ForkJoinTask<T>
ForkJoinPool.submit(ForkJoinTask<T> task)
          Submits a ForkJoinTask for execution.
 

Method parameters in org.infinispan.util.concurrent.jdk8backported with type arguments of type ForkJoinTask
protected  int ForkJoinPool.drainTasksTo(Collection<? super ForkJoinTask<?>> c)
          Removes all available unexecuted submitted and forked tasks from scheduling queues and adds them to the given collection, without altering their execution status.
 


Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.