Package | Description |
---|---|
io.netty.util.internal.chmv8 |
Modifier and Type | Class and Description |
---|---|
(package private) static class |
ConcurrentHashMapV8.BulkTask<K,V,R>
Base class for bulk tasks.
|
(package private) static class |
ConcurrentHashMapV8.ForEachEntryTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.ForEachKeyTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.ForEachMappingTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.ForEachTransformedEntryTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.ForEachTransformedKeyTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.ForEachTransformedMappingTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.ForEachTransformedValueTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.ForEachValueTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceEntriesTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.MapReduceEntriesToDoubleTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceEntriesToIntTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceEntriesToLongTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceKeysTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.MapReduceKeysToDoubleTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceKeysToIntTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceKeysToLongTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceMappingsTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.MapReduceMappingsToDoubleTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceMappingsToIntTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceMappingsToLongTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceValuesTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.MapReduceValuesToDoubleTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceValuesToIntTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.MapReduceValuesToLongTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.ReduceEntriesTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.ReduceKeysTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.ReduceValuesTask<K,V> |
(package private) static class |
ConcurrentHashMapV8.SearchEntriesTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.SearchKeysTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.SearchMappingsTask<K,V,U> |
(package private) static class |
ConcurrentHashMapV8.SearchValuesTask<K,V,U> |
class |
CountedCompleter<T>
A
ForkJoinTask with a completion action performed when
triggered and there are no remaining pending actions. |
(package private) static class |
ForkJoinPool.EmptyTask
Class for artificial tasks that are used to replace the target
of local joins if they are removed from an interior queue slot
in WorkQueue.tryRemoveAndExec.
|
(package private) static class |
ForkJoinTask.AdaptedCallable<T>
Adaptor for Callables
|
(package private) static class |
ForkJoinTask.AdaptedRunnable<T>
Adaptor for Runnables.
|
(package private) static class |
ForkJoinTask.AdaptedRunnableAction
Adaptor for Runnables without results
|
(package private) static class |
ForkJoinTask.RunnableExecuteAction
Adaptor for Runnables in which failure forces worker exception
|
Modifier and Type | Field and Description |
---|---|
(package private) ForkJoinTask<?>[] |
ForkJoinPool.WorkQueue.array |
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.currentJoin |
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.currentSteal |
Modifier and Type | Method and Description |
---|---|
static <T extends ForkJoinTask<?>> |
ForkJoinTask.invokeAll(java.util.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. |
Modifier and Type | Method and Description |
---|---|
static <T> ForkJoinTask<T> |
ForkJoinTask.adapt(java.util.concurrent.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(java.lang.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(java.lang.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() . |
ForkJoinTask<V> |
ForkJoinTask.fork()
Arranges to asynchronously execute this task in the pool the
current task is running in, if applicable, or using the
ForkJoinPool.commonPool() if not inForkJoinPool() . |
(package private) ForkJoinTask<?>[] |
ForkJoinPool.WorkQueue.growArray()
Initializes or doubles the capacity of array.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.nextLocalTask()
Takes next task, if one exists, in order specified by mode.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.nextTaskFor(ForkJoinPool.WorkQueue w)
Gets and removes a local or stolen task for the given worker.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.peek()
Returns next task, if one exists, in order specified by mode.
|
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.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.poll()
Takes next task, if one exists, in FIFO order.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.pollAt(int b)
Takes a task in FIFO order if b is base of queue and a task
can be claimed without contention.
|
protected static ForkJoinTask<?> |
ForkJoinTask.pollNextLocalTask()
Unschedules and returns, without executing, the next task
queued by the current thread but not yet executed, if the
current thread is operating in a ForkJoinPool.
|
protected ForkJoinTask<?> |
ForkJoinPool.pollSubmission()
Removes and returns the next unexecuted submission if one is
available.
|
protected static ForkJoinTask<?> |
ForkJoinTask.pollTask()
If the current thread is operating in a ForkJoinPool,
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.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.WorkQueue.pop()
Takes next task, if one exists, in LIFO order.
|
<T> ForkJoinTask<T> |
ForkJoinPool.submit(java.util.concurrent.Callable<T> task) |
<T> ForkJoinTask<T> |
ForkJoinPool.submit(ForkJoinTask<T> task)
Submits a ForkJoinTask for execution.
|
ForkJoinTask<?> |
ForkJoinPool.submit(java.lang.Runnable task) |
<T> ForkJoinTask<T> |
ForkJoinPool.submit(java.lang.Runnable task,
T result) |
Modifier and Type | Method and Description |
---|---|
(package private) int |
ForkJoinPool.awaitJoin(ForkJoinPool.WorkQueue joiner,
ForkJoinTask<?> task)
Helps and/or blocks until the given task is done.
|
(package private) static void |
ForkJoinTask.cancelIgnoringExceptions(ForkJoinTask<?> t)
Cancels, ignoring any exceptions thrown by cancel.
|
void |
ForkJoinPool.execute(ForkJoinTask<?> task)
Arranges for (asynchronous) execution of the given task.
|
(package private) void |
ForkJoinPool.externalPush(ForkJoinTask<?> task)
Unless shutting down, adds the given task to a submission queue
at submitter's current queue index (modulo submission
range).
|
private void |
ForkJoinPool.fullExternalPush(ForkJoinTask<?> task)
Full version of externalPush.
|
(package private) void |
ForkJoinPool.helpJoinOnce(ForkJoinPool.WorkQueue joiner,
ForkJoinTask<?> task)
Stripped-down variant of awaitJoin used by timed joins.
|
<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. |
(package private) void |
ForkJoinPool.WorkQueue.push(ForkJoinTask<?> task)
Pushes a task.
|
(package private) void |
ForkJoinPool.WorkQueue.runTask(ForkJoinTask<?> task)
Executes a top-level task and any local tasks remaining
after execution.
|
<T> ForkJoinTask<T> |
ForkJoinPool.submit(ForkJoinTask<T> task)
Submits a ForkJoinTask for execution.
|
(package private) boolean |
ForkJoinPool.tryExternalUnpush(ForkJoinTask<?> task)
Tries to pop the given task from submitter's queue in common pool.
|
private int |
ForkJoinPool.tryHelpStealer(ForkJoinPool.WorkQueue joiner,
ForkJoinTask<?> task)
Tries to locate and execute tasks for a stealer of the given
task, or in turn one of its stealers, Traces currentSteal ->
currentJoin links looking for a thread working on a descendant
of the given task and with a non-empty queue to steal back and
execute tasks from.
|
(package private) boolean |
ForkJoinPool.WorkQueue.tryRemoveAndExec(ForkJoinTask<?> task)
If present, removes from queue and executes the given task,
or any other cancelled task.
|
(package private) boolean |
ForkJoinPool.WorkQueue.tryUnpush(ForkJoinTask<?> t)
Pops the given task only if it is at the current top.
|
Modifier and Type | Method and Description |
---|---|
protected int |
ForkJoinPool.drainTasksTo(java.util.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.
|
Constructor and Description |
---|
ExceptionNode(ForkJoinTask<?> task,
java.lang.Throwable ex,
ForkJoinTask.ExceptionNode next) |