org.jboss.threads

Class JBossScheduledThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

org.jboss.threads.JBossScheduledThreadPoolExecutor

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, java.util.concurrent.ScheduledExecutorService, ThreadExecutorMBean, ThreadPoolExecutorMBean, ShutdownListenable

public final class JBossScheduledThreadPoolExecutor
extends java.util.concurrent.ScheduledThreadPoolExecutor
implements ThreadPoolExecutorMBean, ShutdownListenable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	JBossScheduledThreadPoolExecutor.CountingRejectHandler

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicInteger	rejectCount
private SimpleShutdownListenable	shutdownListenable

Constructor Summary

Constructors

Constructor and Description
JBossScheduledThreadPoolExecutor(int corePoolSize)
JBossScheduledThreadPoolExecutor(int corePoolSize, java.util.concurrent.RejectedExecutionHandler handler)
JBossScheduledThreadPoolExecutor(int corePoolSize, java.util.concurrent.ThreadFactory threadFactory)
JBossScheduledThreadPoolExecutor(int corePoolSize, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler handler)

Method Summary

Modifier and Type	Method and Description
<A> void	addShutdownListener(EventListener<A> shutdownListener, A attachment) Add a shutdown listener.
int	getCurrentThreadCount()
long	getKeepAliveTime()
int	getLargestThreadCount()
int	getMaxThreads()
int	getQueueSize()
int	getRejectedCount()
java.util.concurrent.RejectedExecutionHandler	getRejectedExecutionHandler()
void	setKeepAliveTime(long milliseconds)
void	setKeepAliveTime(long time, java.util.concurrent.TimeUnit unit)
void	setMaxThreads(int newSize)
void	setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)
protected void	terminated()

Methods inherited from class java.util.concurrent.ScheduledThreadPoolExecutor

decorateTask, decorateTask, execute, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow, submit, submit, submit

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setMaximumPoolSize, setThreadFactory, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Field Detail

shutdownListenable

private final SimpleShutdownListenable shutdownListenable

rejectCount

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

Constructor Detail

JBossScheduledThreadPoolExecutor

public JBossScheduledThreadPoolExecutor(int corePoolSize)

JBossScheduledThreadPoolExecutor

public JBossScheduledThreadPoolExecutor(int corePoolSize,
                                        java.util.concurrent.ThreadFactory threadFactory)

JBossScheduledThreadPoolExecutor

public JBossScheduledThreadPoolExecutor(int corePoolSize,
                                        java.util.concurrent.RejectedExecutionHandler handler)

JBossScheduledThreadPoolExecutor

public JBossScheduledThreadPoolExecutor(int corePoolSize,
                                        java.util.concurrent.ThreadFactory threadFactory,
                                        java.util.concurrent.RejectedExecutionHandler handler)

Method Detail

getKeepAliveTime

public long getKeepAliveTime()

Specified by:

getKeepAliveTime in interface ThreadPoolExecutorMBean

setKeepAliveTime

public void setKeepAliveTime(long milliseconds)

Specified by:

setKeepAliveTime in interface ThreadPoolExecutorMBean

setKeepAliveTime

public void setKeepAliveTime(long time,
                             java.util.concurrent.TimeUnit unit)

Overrides:

setKeepAliveTime in class java.util.concurrent.ThreadPoolExecutor

getRejectedCount

public int getRejectedCount()

Specified by:

getRejectedCount in interface ThreadExecutorMBean

getCurrentThreadCount

public int getCurrentThreadCount()

Specified by:

getCurrentThreadCount in interface ThreadExecutorMBean

getLargestThreadCount

public int getLargestThreadCount()

Specified by:

getLargestThreadCount in interface ThreadExecutorMBean

getMaxThreads

public int getMaxThreads()

Specified by:

getMaxThreads in interface ThreadPoolExecutorMBean

setMaxThreads

public void setMaxThreads(int newSize)

Specified by:

setMaxThreads in interface ThreadPoolExecutorMBean

getRejectedExecutionHandler

public java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()

Overrides:

getRejectedExecutionHandler in class java.util.concurrent.ThreadPoolExecutor

setRejectedExecutionHandler

public void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)

Overrides:

setRejectedExecutionHandler in class java.util.concurrent.ThreadPoolExecutor

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface ThreadExecutorMBean

addShutdownListener

public <A> void addShutdownListener(EventListener<A> shutdownListener,
                                    A attachment)

Add a shutdown listener. If the target object is already shut down, the listener is invoked directly.

Specified by:

addShutdownListener in interface ShutdownListenable

Type Parameters:

A - the attachment type

Parameters:

shutdownListener - the listener

attachment - the attachment value to pass to the listener

terminated

protected void terminated()

Overrides:

terminated in class java.util.concurrent.ThreadPoolExecutor