| Package | Description |
|---|---|
| java.util.concurrent |
Utility classes commonly useful in concurrent programming.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CountedCompleter<T>
A
ForkJoinTask with a completion action performed when triggered and there are no remaining pending actions.
|
class |
RecursiveAction
A recursive resultless
ForkJoinTask.
|
class |
RecursiveTask<V>
A recursive result-bearing
ForkJoinTask.
|
| Modifier and Type | Method and Description |
|---|---|
static <T extends ForkJoinTask |
ForkJoinTask.invokeAll(Collection
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 |
ForkJoinTask.adapt(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
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 |
ForkJoinTask.adapt(Runnable
Returns a new
ForkJoinTask that performs the
run method of the given
Runnable as its action, and returns the given result upon
join().
|
ForkJoinTask |
ForkJoinTask.fork()
Arranges to asynchronously execute this task in the pool the current task is running in, if applicable, or using the
ForkJoinPool if not
inForkJoinPool().
|
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, 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.
|
<T> ForkJoinTask |
ForkJoinPool.submit(Callable
|
<T> ForkJoinTask |
ForkJoinPool.submit(ForkJoinTask
Submits a ForkJoinTask for execution.
|
ForkJoinTask |
ForkJoinPool.submit(Runnable
|
<T> ForkJoinTask |
ForkJoinPool.submit(Runnable
|
| Modifier and Type | Method and Description |
|---|---|
void |
ForkJoinPool.execute(ForkJoinTask
Arranges for (asynchronous) execution of the given task.
|
<T> T |
ForkJoinPool.invoke(ForkJoinTask
Performs the given task, returning its result upon completion.
|
static void |
ForkJoinTask.invokeAll(ForkJoinTask
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
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
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 |
ForkJoinPool.submit(ForkJoinTask
Submits a ForkJoinTask for execution.
|
| Modifier and Type | Method and Description |
|---|---|
protected int |
ForkJoinPool.drainTasksTo(Collection
Removes all available unexecuted submitted and forked tasks from scheduling queues and adds them to the given collection, without altering their execution status.
|