Modifier and Type	Class and Description
pack-priv static class	DelayScheduler.ScheduledForkJoinTask<T> Task class for DelayScheduler operations

Modifier and Type	Field and Description
pack-priv volatile int	active
private static final long	ACTIVE
pack-priv volatile int	cancelDelayedTasksOnShutdown
private static final int	INITIAL_HEAP_CAPACITY
pack-priv static final long	nanoTimeOffset
pack-priv int	pad0
pack-priv int	pad1
pack-priv int	pad2
pack-priv int	pad3
pack-priv int	pad4
pack-priv int	pad5
pack-priv int	pad6
pack-priv int	pad7
pack-priv int	pad8
pack-priv int	pad9
pack-priv int	padA
pack-priv int	padB
pack-priv int	padC
pack-priv int	padD
pack-priv int	padE
pack-priv volatile DelayScheduler.ScheduledForkJoinTask<?>	pending
private static final long	PENDING
pack-priv ForkJoinPool	pool
private static final int	POOL_STOPPING
pack-priv int	restingSize
private static final Unsafe	U

Access	Constructor and Description
pack-priv	DelayScheduler(ForkJoinPool p, String name)

Method Summary

Modifier and Type	Method and Description
private static void	cancelAll(DelayScheduler.ScheduledForkJoinTask<?>[] h, int n)
pack-priv final void	cancelDelayedTasksOnShutdown() Turns on cancelDelayedTasksOnShutdown policy
pack-priv final boolean	canShutDown() Returns true if (momentarily) inactive and heap is empty
private static boolean	checkHeap(DelayScheduler.ScheduledForkJoinTask<?>[] h, int n) Invariant checks
pack-priv final int	lastStableSize() Returns the number of elements in heap when last idle
private void	loop(ForkJoinPool p) After initialization, repeatedly: 1.
pack-priv static final long	now() Returns System.nanoTime() with nanoTimeOffset
pack-priv final void	pend(DelayScheduler.ScheduledForkJoinTask<?> task) Inserts the task (if nonnull) to pending queue, to add, remove, or ignore depending on task status when processed.
private static int	Returns: current heap size replace(DelayScheduler.ScheduledForkJoinTask<?>[] h, int k, int n) Replaces removed heap element at index k, along with other cancelled nodes found while doing so.
public final void	run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. Sets up and runs scheduling loop
pack-priv final int	signal() Ensures the scheduler is not parked unless stopped.
private int	Returns: negative if stop, else current heap size. tryStop(ForkJoinPool p, DelayScheduler.ScheduledForkJoinTask<?>[] h, int n, int runStatus, int prevRunStatus) Call only when pool run status is nonzero.

Field Detail

active	back to summary
pack-priv volatile int active

ACTIVE	back to summary
private static final long ACTIVE

cancelDelayedTasksOnShutdown	back to summary
pack-priv volatile int cancelDelayedTasksOnShutdown

INITIAL_HEAP_CAPACITY	back to summary
private static final int INITIAL_HEAP_CAPACITY

nanoTimeOffset	back to summary
pack-priv static final long nanoTimeOffset

pad0	back to summary
pack-priv int pad0

pad1	back to summary
pack-priv int pad1

pad2	back to summary
pack-priv int pad2

pad3	back to summary
pack-priv int pad3

pad4	back to summary
pack-priv int pad4

pad5	back to summary
pack-priv int pad5

pad6	back to summary
pack-priv int pad6

pad7	back to summary
pack-priv int pad7

pad8	back to summary
pack-priv int pad8

pad9	back to summary
pack-priv int pad9

padA	back to summary
pack-priv int padA

padB	back to summary
pack-priv int padB

padC	back to summary
pack-priv int padC

padD	back to summary
pack-priv int padD

padE	back to summary
pack-priv int padE

pending	back to summary
pack-priv volatile DelayScheduler.ScheduledForkJoinTask<?> pending

PENDING	back to summary
private static final long PENDING

pool	back to summary
pack-priv ForkJoinPool pool

POOL_STOPPING	back to summary
private static final int POOL_STOPPING

restingSize	back to summary
pack-priv int restingSize

U	back to summary
private static final Unsafe U

Constructor Detail

DelayScheduler	back to summary
pack-priv DelayScheduler(ForkJoinPool p, String name)

Method Detail

cancelAll	back to summary
private static void cancelAll(DelayScheduler.ScheduledForkJoinTask<?>[] h, int n)

cancelDelayedTasksOnShutdown	back to summary
pack-priv final void cancelDelayedTasksOnShutdown() Turns on cancelDelayedTasksOnShutdown policy

canShutDown	back to summary
pack-priv final boolean canShutDown() Returns true if (momentarily) inactive and heap is empty

checkHeap	back to summary
private static boolean checkHeap(DelayScheduler.ScheduledForkJoinTask<?>[] h, int n) Invariant checks

lastStableSize	back to summary
pack-priv final int lastStableSize() Returns the number of elements in heap when last idle

loop	back to summary
private void loop(ForkJoinPool p) After initialization, repeatedly: 1. If apparently no work, if active, set tentatively inactive, else park until next trigger time, or indefinitely if none 2. Process pending tasks in batches, to add or remove from heap 3. Check for shutdown, either exiting or preparing for shutdown when empty 4. Trigger all enabled tasks by submitting them to pool or run if immediate

loop

back to summary

private void loop(ForkJoinPool p)

After initialization, repeatedly: 1. If apparently no work, if active, set tentatively inactive, else park until next trigger time, or indefinitely if none 2. Process pending tasks in batches, to add or remove from heap 3. Check for shutdown, either exiting or preparing for shutdown when empty 4. Trigger all enabled tasks by submitting them to pool or run if immediate

now	back to summary
pack-priv static final long now() Returns System.nanoTime() with nanoTimeOffset

pend	back to summary
pack-priv final void pend(DelayScheduler.ScheduledForkJoinTask<?> task) Inserts the task (if nonnull) to pending queue, to add, remove, or ignore depending on task status when processed.

replace	back to summary
private static int replace(DelayScheduler.ScheduledForkJoinTask<?>[] h, int k, int n) Replaces removed heap element at index k, along with other cancelled nodes found while doing so. Returns:int current heap size

replace

back to summary

private static int replace(DelayScheduler.ScheduledForkJoinTask<?>[] h, int k, int n)

Replaces removed heap element at index k, along with other cancelled nodes found while doing so.

Returns:int: current heap size

run	back to summary
public final void run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. Sets up and runs scheduling loop

run

back to summary

public final void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

Sets up and runs scheduling loop

signal	back to summary
pack-priv final int signal() Ensures the scheduler is not parked unless stopped. Returns negative if already stopped

tryStop	back to summary
private int tryStop(ForkJoinPool p, DelayScheduler.ScheduledForkJoinTask<?>[] h, int n, int runStatus, int prevRunStatus) Call only when pool run status is nonzero. Possibly cancels tasks and stops during pool shutdown and termination. If called when shutdown but not stopping, removes tasks according to policy if not already done so, and if not empty or pool not terminating, returns. Otherwise, cancels all tasks in heap and pending queue. Returns:int negative if stop, else current heap size.

tryStop

back to summary

private int tryStop(ForkJoinPool p, DelayScheduler.ScheduledForkJoinTask<?>[] h, int n, int runStatus, int prevRunStatus)

Call only when pool run status is nonzero. Possibly cancels tasks and stops during pool shutdown and termination. If called when shutdown but not stopping, removes tasks according to policy if not already done so, and if not empty or pool not terminating, returns. Otherwise, cancels all tasks in heap and pending queue.

Returns:int: negative if stop, else current heap size.

java.util.concurrent back to summary

pack-priv final Class DelayScheduler.ScheduledForkJoinTask<T>

Class Inheritance

extends ForkJoinTask.InterruptibleTask<T>
implements ScheduledFuture<T>

java.lang.Object
java.util.concurrent.ForkJoinTask
java.util.concurrent.ForkJoinTask.InterruptibleTask
java.util.concurrent.DelayScheduler.ScheduledForkJoinTask

All Implemented Interfaces

java.util.concurrent.ScheduledFuture, java.util.concurrent.Future, java.util.concurrent.Delayed, java.lang.Comparable

Annotations

@SuppressWarnings:serial

Task class for DelayScheduler operations

Field Summary

Modifier and Type	Field and Description
pack-priv Callable<? extends T>	callable
pack-priv int	heapIndex
pack-priv final boolean	isImmediate
pack-priv final long	nextDelay
pack-priv DelayScheduler.ScheduledForkJoinTask<?>	nextPending
pack-priv ForkJoinPool	pool
pack-priv T	result
pack-priv Runnable	runnable
pack-priv long	when

Inherited from java.util.concurrent.ForkJoinTask.InterruptibleTask:: runner

Constructor Summary

Access	Constructor and Description
public	ScheduledForkJoinTask(long initial delay, in nanoseconds delay, long 0 for one-shot, negative for fixed delay, positive for fixed rate, in nanoseconds nextDelay, boolean if action is to be performed by scheduler versus submitting to a WorkQueue isImmediate, Runnable action (null if implementing callable version) runnable, Callable<T> function (null if implementing runnable versions) callable, ForkJoinPool the pool for resubmissions and cancellations (disabled if null) pool) Creates a new ScheduledForkJoinTask

Access

Constructor and Description

public

ScheduledForkJoinTask(long

initial delay, in nanoseconds

delay, long

0 for one-shot, negative for fixed delay, positive for fixed rate, in nanoseconds

nextDelay, boolean

if action is to be performed by scheduler versus submitting to a WorkQueue

isImmediate, Runnable

action (null if implementing callable version)

runnable, Callable<T>

function (null if implementing runnable versions)

callable, ForkJoinPool

the pool for resubmissions and cancellations (disabled if null)

pool)

Creates a new ScheduledForkJoinTask

Method Summary

Modifier and Type	Method and Description
pack-priv final Object	adaptee() Overrides java.util.concurrent.ForkJoinTask.InterruptibleTask.adaptee.
public final boolean	cancel(boolean mayInterruptIfRunning) Overrides java.util.concurrent.ForkJoinTask.InterruptibleTask.cancel. Implements java.util.concurrent.Future.cancel. Attempts to cancel execution of this task.
public int	compareTo(Delayed other) Implements java.lang.Comparable.compareTo. Compares this object with the specified object for order.
pack-priv final T	compute() Implements abstract java.util.concurrent.ForkJoinTask.InterruptibleTask.compute.
public final long	getDelay(TimeUnit unit) Implements java.util.concurrent.Delayed.getDelay. Returns the remaining delay associated with this object, in the given time unit.
public final T	getRawResult() Implements abstract java.util.concurrent.ForkJoinTask.getRawResult. Returns the result that would be returned by `join`, even if this task completed abnormally, or `null` if this task is not known to have been completed.
pack-priv final boolean	postExec() Overrides java.util.concurrent.ForkJoinTask.InterruptibleTask.postExec.
public void	schedule()
public final void	setRawResult(T v) Implements abstract java.util.concurrent.ForkJoinTask.setRawResult. Forces the given value to be returned as a result.

Inherited from java.util.concurrent.ForkJoinTask.InterruptibleTask:: exec interruptIfRunning run toString

Field Detail

callable	back to summary
pack-priv Callable<? extends T> callable

heapIndex	back to summary
pack-priv int heapIndex

isImmediate	back to summary
pack-priv final boolean isImmediate

nextDelay	back to summary
pack-priv final long nextDelay

nextPending	back to summary
pack-priv DelayScheduler.ScheduledForkJoinTask<?> nextPending

pool	back to summary
pack-priv ForkJoinPool pool

result	back to summary
pack-priv T result

runnable	back to summary
pack-priv Runnable runnable

when	back to summary
pack-priv long when

Constructor Detail

ScheduledForkJoinTask

back to summary

public ScheduledForkJoinTask(long delay, long nextDelay, boolean isImmediate, Runnable runnable, Callable<T> callable, ForkJoinPool pool)

Creates a new ScheduledForkJoinTask

Parameters

delay:long: initial delay, in nanoseconds
nextDelay:long: 0 for one-shot, negative for fixed delay, positive for fixed rate, in nanoseconds
isImmediate:boolean: if action is to be performed by scheduler versus submitting to a WorkQueue
runnable:Runnable: action (null if implementing callable version)
callable:Callable<T>: function (null if implementing runnable versions)
pool:ForkJoinPool: the pool for resubmissions and cancellations (disabled if null)

Method Detail

adaptee	back to summary
pack-priv final Object adaptee() Overrides java.util.concurrent.ForkJoinTask.InterruptibleTask.adaptee.

cancel back to summary

public final boolean cancel(boolean mayInterruptIfRunning)

Overrides java.util.concurrent.ForkJoinTask.InterruptibleTask.cancel.

Implements java.util.concurrent.Future.cancel.

Doc from java.util.concurrent.Future.cancel.

Attempts to cancel execution of this task. This method has no effect if the task is already completed or cancelled, or could not be cancelled for some other reason. Otherwise, if this task has not started when cancel is called, this task should never run. If the task has already started, then the mayInterruptIfRunning parameter determines whether the thread executing this task (when known by the implementation) is interrupted in an attempt to stop the task.

The return value from this method does not necessarily indicate whether the task is now cancelled; use isCancelled.

compareTo back to summary

public int compareTo(Delayed other)

Implements java.lang.Comparable.compareTo.

Doc from java.lang.Comparable.compareTo.

Compares this object with the specified object for order. Returns a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object.

The implementor must ensure signum(x.compareTo(y)) == -signum(y.compareTo(x)) for all x and y. (This implies that x.compareTo(y) must throw an exception if and only if y.compareTo(x) throws an exception.)

The implementor must also ensure that the relation is transitive: (x.compareTo(y) > 0 && y.compareTo(z) > 0) implies x.compareTo(z) > 0.

Finally, the implementor must ensure that x.compareTo(y)==0 implies that signum(x.compareTo(z)) == signum(y.compareTo(z)), for all z.

compute	back to summary
pack-priv final T compute() throws Exception Implements abstract java.util.concurrent.ForkJoinTask.InterruptibleTask.compute.

getDelay

back to summary

public final long getDelay(TimeUnit unit)

Implements java.util.concurrent.Delayed.getDelay.

Doc from java.util.concurrent.Delayed.getDelay.

Returns the remaining delay associated with this object, in the given time unit.

getRawResult back to summary

public final T getRawResult()

Implements abstract java.util.concurrent.ForkJoinTask.getRawResult.

Doc from java.util.concurrent.ForkJoinTask.getRawResult.

Returns the result that would be returned by join, even if this task completed abnormally, or null if this task is not known to have been completed. This method is designed to aid debugging, as well as to support extensions. Its use in any other context is discouraged.

postExec	back to summary
pack-priv final boolean postExec() Overrides java.util.concurrent.ForkJoinTask.InterruptibleTask.postExec.

schedule	back to summary
public void schedule()

setRawResult

back to summary

public final void setRawResult(T v)

Implements abstract java.util.concurrent.ForkJoinTask.setRawResult.

Doc from java.util.concurrent.ForkJoinTask.setRawResult.

Forces the given value to be returned as a result. This method is designed to support extensions, and should not in general be called otherwise.

pack-priv final Class DelayScheduler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class DelayScheduler.ScheduledForkJoinTask<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail