|
||||||||
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 is
not equal to the given phase value or this phaser is
terminated.
InterruptedException
if interrupted while waiting, or
returning immediately if the current phase is not equal to the
given phase value or this phaser is terminated.
join
and related operations.
join
and related operations.
true
if this queue contains the specified element.
ThreadLocalRandom
.
ExecutorService
for running ForkJoinTask
s.ForkJoinPool
with parallelism equal to Runtime.availableProcessors()
, using the default thread factory,
no UncaughtExceptionHandler, and non-async LIFO processing mode.
ForkJoinPool
with the indicated parallelism
level, the default thread factory,
no UncaughtExceptionHandler, and non-async LIFO processing mode.
ForkJoinPool
with the given parameters.
ForkJoinWorkerThread
s.ForkJoinPool
s.ForkJoinPool
.ForkJoinPool
, which executes
ForkJoinTask
s.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.
null
if none.
ForkJoinTask.join()
, even
if this task completed abnormally, or null
if this task
is not known to have been completed.
null
.
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 quiescent
.
true
if the current thread is a ForkJoinWorkerThread
executing as a ForkJoinPool computation.
RuntimeException
or Error
if the underlying
computation did so.
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, in which case the exception is rethrown.
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 phaser 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.Phaser(parent, 0)
.
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 |