|
||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||
ForkJoinTask that performs the run
method of the given Runnable as its action, and returns
a null result upon ForkJoinTask.join().
ForkJoinTask that performs the run
method of the given Runnable as its action, and returns
the given result upon ForkJoinTask.join().
ForkJoinTask that performs the call
method of the given Callable as its action, and returns
its result upon ForkJoinTask.join(), translating any checked exceptions
encountered into RuntimeException.
InterruptedException if interrupted
while waiting, or returning immediately if the current phase of
the barrier is not equal to the given phase value or this
barrier is terminated.
InterruptedException if interrupted while waiting, or
returning immediately if the current phase of the barrier is
not equal to the given phase value or this barrier is
terminated.
null result upon join and related
operations.
join and related operations.
ThreadLocalRandom.
ExecutorService for running ForkJoinTasks.ForkJoinPool with parallelism equal to Runtime.availableProcessors(), and using the default thread factory.
ForkJoinPool with the indicated parallelism
level and using the default thread factory.
ForkJoinPool with parallelism equal to Runtime.availableProcessors(), and using the given
thread factory.
ForkJoinPool with the given parallelism and
thread factory.
ForkJoinWorkerThreads.ForkJoinPools.ForkJoinPool.ForkJoinPool.true if this pool uses local first-in-first-out
scheduling mode for forked tasks that are never joined.
CancellationException if cancelled, or null if
none or if the method has not yet completed.
true if this pool dynamically maintains its
target parallelism level.
null if none.
ForkJoinTask.join(), even
if this task completed abnormally, or null if this task
is not known to have been completed.
BlockingQueue.take() or timed
poll.
true if there are any tasks submitted to this
pool that have not yet begun executing.
true if there is at least one consumer waiting
to receive an element via BlockingQueue.take() or
timed poll.
is
done, then returns the result of the computation.
is quiescent.
true if the current thread is executing as a
ForkJoinPool computation.
isDone holds for
each task or an (unchecked) exception is encountered, in which
case the exception is rethrown.
isDone holds for
each task or an (unchecked) exception is encountered, in which
case the exception is rethrown.
isDone holds for each task or an (unchecked) exception
is encountered.
true if this task threw an exception or was cancelled.
true if this task completed without throwing an
exception and was not cancelled.
true if this queue contains no elements.
true if all worker threads are currently idle.
true if blocking is unnecessary.
true if this pool has been shut down.
true if all tasks have completed following shut down.
true if this barrier has been terminated.
true if the process of termination has
commenced but not yet completed.
is done.
TransferQueue based on linked nodes.LinkedTransferQueue.
LinkedTransferQueue
initially containing the elements of the given collection,
added in traversal order of the collection's iterator.
double value
between 0 (inclusive) and the specified value (exclusive).
CyclicBarrier and
CountDownLatch
but supporting more flexible usage.is
done.
ForkJoinTask.ForkJoinTask.fork.
Integer.MAX_VALUE because a
LinkedTransferQueue is not capacity constrained.
UnsupportedOperationException.
BlockingQueue in which producers may wait for consumers
to receive elements.
|
||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||