org.jboss.threads

Class ThreadFactoryExecutor

java.lang.Object

org.jboss.threads.ThreadFactoryExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, BlockingExecutor, BoundedThreadPoolExecutorMBean, ThreadExecutorMBean, ThreadPoolExecutorMBean

class ThreadFactoryExecutor
extends java.lang.Object
implements BlockingExecutor, BoundedThreadPoolExecutorMBean

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	blocking
private int	currentThreadCount
private java.util.concurrent.ThreadFactory	factory
private int	largestThreadCount
private java.util.concurrent.Semaphore	limitSemaphore
private java.lang.Object	lock
private int	maxThreads
private java.util.concurrent.atomic.AtomicInteger	rejected
private DirectExecutor	taskExecutor

Constructor Summary

Constructors

Constructor and Description
ThreadFactoryExecutor(java.util.concurrent.ThreadFactory factory, int maxThreads, boolean blocking, DirectExecutor taskExecutor)

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable task) Executes the given command at some time in the future.
void	executeBlocking(java.lang.Runnable task) Execute a task, blocking until it can be accepted, or until the calling thread is interrupted.
void	executeBlocking(java.lang.Runnable task, long timeout, java.util.concurrent.TimeUnit unit) Execute a task, blocking until it can be accepted, a timeout elapses, or the calling thread is interrupted.
void	executeNonBlocking(java.lang.Runnable task) Execute a task, without blocking.
int	getCurrentThreadCount()
long	getKeepAliveTime()
int	getLargestThreadCount()
int	getMaxThreads()
int	getQueueSize()
int	getRejectedCount()
boolean	isBlocking()
void	setBlocking(boolean blocking)
void	setKeepAliveTime(long milliseconds)
void	setMaxThreads(int maxThreads)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

factory

private final java.util.concurrent.ThreadFactory factory

limitSemaphore

private final java.util.concurrent.Semaphore limitSemaphore

taskExecutor

private final DirectExecutor taskExecutor

lock

private final java.lang.Object lock

maxThreads

private int maxThreads

largestThreadCount

private int largestThreadCount

currentThreadCount

private int currentThreadCount

rejected

private final java.util.concurrent.atomic.AtomicInteger rejected

blocking

private volatile boolean blocking

Constructor Detail

ThreadFactoryExecutor

ThreadFactoryExecutor(java.util.concurrent.ThreadFactory factory,
                      int maxThreads,
                      boolean blocking,
                      DirectExecutor taskExecutor)

Method Detail

getMaxThreads

public int getMaxThreads()

Specified by:

getMaxThreads in interface ThreadPoolExecutorMBean

setMaxThreads

public void setMaxThreads(int maxThreads)

Specified by:

setMaxThreads in interface ThreadPoolExecutorMBean

execute

public void execute(java.lang.Runnable task)

Description copied from interface: BlockingExecutor

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. The call may block or not block, depending on the configuration of the executor.

Specified by:

execute in interface java.util.concurrent.Executor

Specified by:

execute in interface BlockingExecutor

Parameters:

task - the task to submit

executeBlocking

public void executeBlocking(java.lang.Runnable task)
                     throws java.util.concurrent.RejectedExecutionException,
                            java.lang.InterruptedException

Description copied from interface: BlockingExecutor

Execute a task, blocking until it can be accepted, or until the calling thread is interrupted.

Specified by:

executeBlocking in interface BlockingExecutor

Parameters:

task - the task to submit

Throws:

StoppedExecutorException - if the executor was shut down before the task was accepted

ThreadCreationException - if a thread could not be created for some reason

java.util.concurrent.RejectedExecutionException - if execution is rejected for some other reason

java.lang.InterruptedException - if the current thread was interrupted before the task could be accepted

executeBlocking

public void executeBlocking(java.lang.Runnable task,
                            long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.util.concurrent.RejectedExecutionException,
                            java.lang.InterruptedException

Description copied from interface: BlockingExecutor

Execute a task, blocking until it can be accepted, a timeout elapses, or the calling thread is interrupted.

Specified by:

executeBlocking in interface BlockingExecutor

Parameters:

task - the task to submit

timeout - the amount of time to wait

unit - the unit of time

Throws:

ExecutionTimedOutException - if the timeout elapsed before a task could be accepted

StoppedExecutorException - if the executor was shut down before the task was accepted

ThreadCreationException - if a thread could not be created for some reason

java.util.concurrent.RejectedExecutionException - if execution is rejected for some other reason

java.lang.InterruptedException - if the current thread was interrupted before the task could be accepted

executeNonBlocking

public void executeNonBlocking(java.lang.Runnable task)
                        throws java.util.concurrent.RejectedExecutionException

Description copied from interface: BlockingExecutor

Execute a task, without blocking.

Specified by:

executeNonBlocking in interface BlockingExecutor

Parameters:

task - the task to submit

Throws:

StoppedExecutorException - if the executor was shut down before the task was accepted

ThreadCreationException - if a thread could not be created for some reason

java.util.concurrent.RejectedExecutionException - if execution is rejected for some other reason

isBlocking

public boolean isBlocking()

Specified by:

isBlocking in interface BoundedThreadPoolExecutorMBean

setBlocking

public void setBlocking(boolean blocking)

Specified by:

setBlocking in interface BoundedThreadPoolExecutorMBean

getLargestThreadCount

public int getLargestThreadCount()

Specified by:

getLargestThreadCount in interface ThreadExecutorMBean

getCurrentThreadCount

public int getCurrentThreadCount()

Specified by:

getCurrentThreadCount in interface ThreadExecutorMBean

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface ThreadExecutorMBean

getRejectedCount

public int getRejectedCount()

Specified by:

getRejectedCount in interface ThreadExecutorMBean

getKeepAliveTime

public long getKeepAliveTime()

Specified by:

getKeepAliveTime in interface ThreadPoolExecutorMBean

setKeepAliveTime

public void setKeepAliveTime(long milliseconds)

Specified by:

setKeepAliveTime in interface ThreadPoolExecutorMBean

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object