Modifier and Type	Class and Description
private class	EnhancedViewExecutor.EnhancedViewExecutorRunnable

Field Summary

Modifier and Type	Field and Description
private static final long	ACTIVE_COUNT_MASK
private final Set<EnhancedViewExecutor.EnhancedViewExecutorRunnable>	activeRunnables
private final Executor	delegate
private final Lock	executeLock The execute lock is only needed necessary to guard from submitting the first queued task before the last non-queued (active == maxCount) task can be submitted to the executor.
private volatile boolean	interrupted
private static final Logger	log
private static final int	MAX_QUEUE_SPINS
private final int	maxCount
private final Queue<EnhancedViewExecutor.EnhancedViewExecutorRunnable>	queue Queue handling: The queue must only be modified after a successful CAS `state` update.
private static final int	QUEUE_FAILURE_LOG_INTERVAL
private static final long	QUEUED_SIZE_MASK
private static final int	QUEUED_SIZE_OFFSET
private final int	queueLimit
private static final long	SHUTDOWN_MASK
private final Object	shutdownLock
private volatile long	state State structure.
private static final long	stateOffset

Access	Constructor and Description
pack-priv	EnhancedViewExecutor(final Executor delegate, final int maxCount, final int queueLimit, final Thread.UncaughtExceptionHandler uncaughtExceptionHandler)

Method Summary

Modifier and Type	Method and Description
public boolean	awaitTermination(long the maximum time to wait timeout, TimeUnit the time unit of the timeout argument unit) Implements java.util.concurrent.ExecutorService.awaitTermination. Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.
private EnhancedViewExecutor.EnhancedViewExecutorRunnable	blockingTake() Tasks are enqueued after a successful state update, they may not be immediately available at this point.
private boolean	compareAndSwapState(long expected, long update)
private boolean	decrementQueueSize()
private void	enqueue(EnhancedViewExecutor.EnhancedViewExecutorRunnable task) Only called after the queue size component of `state` has been updated.
public void	execute(Runnable the runnable task task) Implements java.util.concurrent.Executor.execute. Executes the given command at some time in the future.
private static int	getActiveCount(long state)
private static int	getQueueSize(long state)
public boolean	isShutdown() Implements java.util.concurrent.ExecutorService.isShutdown. Returns `true` if this executor has been shut down.
private static boolean	isShutdown(long state)
public boolean	isTerminated() Implements java.util.concurrent.ExecutorService.isTerminated. Returns `true` if all tasks have completed following shut down.
private static boolean	isTerminated(long state)
private void	notifyWaitersIfTerminated(long stateSnapshot)
public void	shutdown(boolean interrupt) Implements abstract org.jboss.threads.ViewExecutor.shutdown.
public List<Runnable>	shutdownNow() Implements java.util.concurrent.ExecutorService.shutdownNow. Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.
private EnhancedViewExecutor.EnhancedViewExecutorRunnable	taskComplete(boolean allowQueuePolling)
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.
private Thread.UncaughtExceptionHandler	uncaughtExceptionHandler()

Inherited from org.jboss.threads.ViewExecutor:: builder getExceptionHandler getTerminationTask readIntPropertyPrefixed readProperty readPropertyPrefixed readPropertyRaw runTermination setExceptionHandler setTerminationTask shutdown

Field Detail

ACTIVE_COUNT_MASK	back to summary
private static final long ACTIVE_COUNT_MASK

activeRunnables	back to summary
private final Set<EnhancedViewExecutor.EnhancedViewExecutorRunnable> activeRunnables

delegate	back to summary
private final Executor delegate

executeLock	back to summary
private final Lock executeLock The execute lock is only needed necessary to guard from submitting the first queued task before the last non-queued (active == maxCount) task can be submitted to the executor. Locks are not used when the queue is disabled. This lock is required to prevent tasks from beginning to queue while tasks that have acquired permits have not been successfully submitted to the delegate executor. In this case the queue may be left in an unrecoverable state if the delegate executor rejects input. Annotations @Nullable

executeLock

back to summary

private final Lock executeLock

The execute lock is only needed necessary to guard from submitting the first queued task before the last non-queued (active == maxCount) task can be submitted to the executor. Locks are not used when the queue is disabled. This lock is required to prevent tasks from beginning to queue while tasks that have acquired permits have not been successfully submitted to the delegate executor. In this case the queue may be left in an unrecoverable state if the delegate executor rejects input.

Annotations

@Nullable

interrupted	back to summary
private volatile boolean interrupted

log	back to summary
private static final Logger log

MAX_QUEUE_SPINS	back to summary
private static final int MAX_QUEUE_SPINS

maxCount	back to summary
private final int maxCount

queue	back to summary
private final Queue<EnhancedViewExecutor.EnhancedViewExecutorRunnable> queue Queue handling: The queue must only be modified after a successful CAS `state` update. After the queue length component of `state` has been decremented a receiver may need to wait for the producer to successfully add an item to the queue.

QUEUE_FAILURE_LOG_INTERVAL	back to summary
private static final int QUEUE_FAILURE_LOG_INTERVAL

QUEUED_SIZE_MASK	back to summary
private static final long QUEUED_SIZE_MASK

QUEUED_SIZE_OFFSET	back to summary
private static final int QUEUED_SIZE_OFFSET

queueLimit	back to summary
private final int queueLimit

SHUTDOWN_MASK	back to summary
private static final long SHUTDOWN_MASK

shutdownLock	back to summary
private final Object shutdownLock

state	back to summary
private volatile long state State structure. Bit 00..30: Number of active tasks (unsigned) Bit 31..61: Number of queued tasks (unsigned) Bit 62: unused; always zero Bit 63: executor shutdown state; 0 = shutdown has not been requested Annotations @SuppressWarnings:unused

state

back to summary

private volatile long state

State structure.

Bit 00..30: Number of active tasks (unsigned)
Bit 31..61: Number of queued tasks (unsigned)
Bit 62: unused; always zero
Bit 63: executor shutdown state; 0 = shutdown has not been requested

Annotations

@SuppressWarnings:unused

stateOffset	back to summary
private static final long stateOffset

Constructor Detail

EnhancedViewExecutor	back to summary
pack-priv EnhancedViewExecutor(final Executor delegate, final int maxCount, final int queueLimit, final Thread.UncaughtExceptionHandler uncaughtExceptionHandler)

Method Detail

awaitTermination back to summary

awaitTermination	back to summary
public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException Implements java.util.concurrent.ExecutorService.awaitTermination. Doc from java.util.concurrent.ExecutorService.awaitTermination. Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first. Parameters timeout:long the maximum time to wait unit:TimeUnit the time unit of the timeout argument Returns:boolean `true` if this executor terminated and `false` if the timeout elapsed before termination Annotations @Override Exceptions InterruptedException: if interrupted while waiting

public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException

Implements java.util.concurrent.ExecutorService.awaitTermination.

Doc from java.util.concurrent.ExecutorService.awaitTermination.

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Parameters

timeout:long: the maximum time to wait
unit:TimeUnit: the time unit of the timeout argument

Returns:boolean

true if this executor terminated and false if the timeout elapsed before termination

Annotations

@Override

Exceptions

InterruptedException:: if interrupted while waiting

blockingTake	back to summary
private EnhancedViewExecutor.EnhancedViewExecutorRunnable blockingTake() Tasks are enqueued after a successful state update, they may not be immediately available at this point.

compareAndSwapState	back to summary
private boolean compareAndSwapState(long expected, long update)

decrementQueueSize	back to summary
private boolean decrementQueueSize()

enqueue	back to summary
private void enqueue(EnhancedViewExecutor.EnhancedViewExecutorRunnable task) Only called after the queue size component of `state` has been updated. At this point there may already be a thread waiting for the queued task after decrementing the queued count, so it's vital that this operation succeeds.

execute back to summary

execute	back to summary
public void execute(Runnable task) Implements java.util.concurrent.Executor.execute. Doc from java.util.concurrent.Executor.execute. Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the `Executor` implementation. Parameters task:Runnable the runnable task Annotations @Override

public void execute(Runnable task)

Implements java.util.concurrent.Executor.execute.

Doc from java.util.concurrent.Executor.execute.

Executes the given command at some time in the future. The command may execute in a new thread, in a pooled thread, or in the calling thread, at the discretion of the Executor implementation.

Parameters

task:Runnable: the runnable task

Annotations

@Override

getActiveCount	back to summary
private static int getActiveCount(long state)

getQueueSize	back to summary
private static int getQueueSize(long state)

isShutdown back to summary

isShutdown	back to summary
public boolean isShutdown() Implements java.util.concurrent.ExecutorService.isShutdown. Doc from java.util.concurrent.ExecutorService.isShutdown. Returns `true` if this executor has been shut down. Returns:boolean `true` if this executor has been shut down Annotations @Override

public boolean isShutdown()

Implements java.util.concurrent.ExecutorService.isShutdown.

Doc from java.util.concurrent.ExecutorService.isShutdown.

Returns true if this executor has been shut down.

Returns:boolean

true if this executor has been shut down

Annotations

@Override

isShutdown	back to summary
private static boolean isShutdown(long state)

isTerminated back to summary

isTerminated	back to summary
public boolean isTerminated() Implements java.util.concurrent.ExecutorService.isTerminated. Doc from java.util.concurrent.ExecutorService.isTerminated. Returns `true` if all tasks have completed following shut down. Note that `isTerminated` is never `true` unless either `shutdown` or `shutdownNow` was called first. Returns:boolean `true` if all tasks have completed following shut down Annotations @Override

public boolean isTerminated()

Implements java.util.concurrent.ExecutorService.isTerminated.

Doc from java.util.concurrent.ExecutorService.isTerminated.

Returns true if all tasks have completed following shut down. Note that isTerminated is never true unless either shutdown or shutdownNow was called first.

Returns:boolean

true if all tasks have completed following shut down

Annotations

@Override

isTerminated	back to summary
private static boolean isTerminated(long state)

notifyWaitersIfTerminated	back to summary
private void notifyWaitersIfTerminated(long stateSnapshot)

shutdown	back to summary
public void shutdown(boolean interrupt) Implements abstract org.jboss.threads.ViewExecutor.shutdown. Annotations @Override

shutdown

back to summary

public void shutdown(boolean interrupt)

Implements abstract org.jboss.threads.ViewExecutor.shutdown.

Annotations

@Override

shutdownNow back to summary

shutdownNow	back to summary
public List<Runnable> shutdownNow() Implements java.util.concurrent.ExecutorService.shutdownNow. Doc from java.util.concurrent.ExecutorService.shutdownNow. Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution. This method does not wait for actively executing tasks to terminate. Use `awaitTermination` to do that. There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via `Thread#interrupt`, so any task that fails to respond to interrupts may never terminate. Returns:List<Runnable> list of tasks that never commenced execution Annotations @Override

public List<Runnable> shutdownNow()

Implements java.util.concurrent.ExecutorService.shutdownNow.

Doc from java.util.concurrent.ExecutorService.shutdownNow.

Attempts to stop all actively executing tasks, halts the processing of waiting tasks, and returns a list of the tasks that were awaiting execution.

This method does not wait for actively executing tasks to terminate. Use awaitTermination to do that.

There are no guarantees beyond best-effort attempts to stop processing actively executing tasks. For example, typical implementations will cancel via Thread#interrupt, so any task that fails to respond to interrupts may never terminate.

Returns:List<Runnable>

list of tasks that never commenced execution

Annotations

@Override

taskComplete	back to summary
private EnhancedViewExecutor.EnhancedViewExecutorRunnable taskComplete(boolean allowQueuePolling)

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

uncaughtExceptionHandler	back to summary
private Thread.UncaughtExceptionHandler uncaughtExceptionHandler()

org.jboss.threads back to summary

private final Class EnhancedViewExecutor.EnhancedViewExecutorRunnable

Class Inheritance

extends Object
implements Runnable

java.lang.Object
org.jboss.threads.EnhancedViewExecutor.EnhancedViewExecutorRunnable

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private ClassLoader	contextClassLoader
private Runnable	delegate
private volatile Thread	thread

Constructor Summary

Access	Constructor and Description
pack-priv	EnhancedViewExecutorRunnable(Runnable delegate, ClassLoader contextClassLoader)

Method Summary

Modifier and Type	Method and Description
pack-priv synchronized void	interrupt()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

contextClassLoader	back to summary
private ClassLoader contextClassLoader

delegate	back to summary
private Runnable delegate

thread	back to summary
private volatile Thread thread Annotations @Nullable

Constructor Detail

EnhancedViewExecutorRunnable	back to summary
pack-priv EnhancedViewExecutorRunnable(Runnable delegate, ClassLoader contextClassLoader)

Method Detail

interrupt	back to summary
pack-priv synchronized void interrupt()

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Returns:String a string representation of the object. Annotations @Override

toString

back to summary

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object.

Returns:String

a string representation of the object.

Annotations

@Override

pack-priv final Class EnhancedViewExecutor

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class EnhancedViewExecutor.EnhancedViewExecutorRunnable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail