Package | Description |
---|---|
io.netty.util.internal.chmv8 |
Modifier and Type | Field and Description |
---|---|
(package private) ForkJoinPool.WorkQueue |
ForkJoinWorkerThread.workQueue |
(package private) ForkJoinPool.WorkQueue[] |
ForkJoinPool.workQueues |
Modifier and Type | Method and Description |
---|---|
(package private) static ForkJoinPool.WorkQueue |
ForkJoinPool.commonSubmitterQueue()
Returns common pool queue for a thread that has submitted at
least one task.
|
private ForkJoinPool.WorkQueue |
ForkJoinPool.findNonEmptyStealQueue()
Returns a (probably) non-empty steal queue, if one is found
during a scan, else null.
|
(package private) ForkJoinPool.WorkQueue |
ForkJoinPool.registerWorker(ForkJoinWorkerThread wt)
Callback from ForkJoinWorkerThread to establish and record its
WorkQueue.
|
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.
|
private int |
ForkJoinPool.awaitWork(ForkJoinPool.WorkQueue w,
long c,
int ec)
A continuation of scan(), possibly blocking or terminating
worker w.
|
private int |
ForkJoinPool.helpComplete(ForkJoinPool.WorkQueue joiner,
CountedCompleter<?> task)
Analog of tryHelpStealer for CountedCompleters.
|
(package private) void |
ForkJoinPool.helpJoinOnce(ForkJoinPool.WorkQueue joiner,
ForkJoinTask<?> task)
Stripped-down variant of awaitJoin used by timed joins.
|
(package private) void |
ForkJoinPool.helpQuiescePool(ForkJoinPool.WorkQueue w)
Runs tasks until
isQuiescent() . |
private void |
ForkJoinPool.helpRelease(long c,
ForkJoinPool.WorkQueue[] ws,
ForkJoinPool.WorkQueue w,
ForkJoinPool.WorkQueue q,
int b)
Possibly releases (signals) a worker.
|
private void |
ForkJoinPool.helpRelease(long c,
ForkJoinPool.WorkQueue[] ws,
ForkJoinPool.WorkQueue w,
ForkJoinPool.WorkQueue q,
int b)
Possibly releases (signals) a worker.
|
(package private) ForkJoinTask<?> |
ForkJoinPool.nextTaskFor(ForkJoinPool.WorkQueue w)
Gets and removes a local or stolen task for the given worker.
|
(package private) void |
ForkJoinPool.runWorker(ForkJoinPool.WorkQueue w)
Top-level runloop for workers, called by ForkJoinWorkerThread.run.
|
private int |
ForkJoinPool.scan(ForkJoinPool.WorkQueue w,
int r)
Scans for and, if found, runs one task, else possibly
inactivates the worker.
|
(package private) void |
ForkJoinPool.signalWork(ForkJoinPool.WorkQueue[] ws,
ForkJoinPool.WorkQueue q)
Tries to create or activate a worker if too few are active.
|
(package private) void |
ForkJoinPool.signalWork(ForkJoinPool.WorkQueue[] ws,
ForkJoinPool.WorkQueue q)
Tries to create or activate a worker if too few are active.
|
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.
|