org.camunda.bpm.container.impl.jmx.services

Class JmxManagedThreadPool

java.lang.Object

org.camunda.bpm.container.impl.threading.se.SeExecutorService

org.camunda.bpm.container.impl.jmx.services.JmxManagedThreadPool

All Implemented Interfaces:

ExecutorService, MBeanService<JmxManagedThreadPool>, JmxManagedThreadPoolMBean

public class JmxManagedThreadPool
extends SeExecutorService
implements JmxManagedThreadPoolMBean, MBeanService<JmxManagedThreadPool>

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingQueue<Runnable>	threadPoolQueue

Fields inherited from class org.camunda.bpm.container.impl.threading.se.SeExecutorService

threadPoolExecutor

Constructor Summary

Constructors

Constructor and Description
JmxManagedThreadPool(BlockingQueue<Runnable> queue, ThreadPoolExecutor executor)

Method Summary

Methods

Modifier and Type	Method and Description
int	getActiveCount()
long	getCompletedTaskCount()
int	getLargestPoolSize()
int	getMaximumPoolSize()
int	getPoolSize()
int	getQueueCount()
long	getTaskCount()
ThreadPoolExecutor	getThreadPoolExecutor()
JmxManagedThreadPool	getValue()
void	purgeThreadPool()
void	setCorePoolSize(int corePoolSize)
void	setKeepAliveTime(long time, TimeUnit unit)
void	setMaximumPoolSize(int maximumPoolSize)
void	start(MBeanServiceContainer mBeanServiceContainer)
void	stop(MBeanServiceContainer mBeanServiceContainer)

Methods inherited from class org.camunda.bpm.container.impl.threading.se.SeExecutorService

executeLongRunning, executeShortRunning, getExecuteJobsRunnable, schedule

Methods inherited from class java.lang.Object

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

Field Detail

threadPoolQueue

protected final BlockingQueue<Runnable> threadPoolQueue

Constructor Detail

JmxManagedThreadPool

public JmxManagedThreadPool(BlockingQueue<Runnable> queue,
                    ThreadPoolExecutor executor)

Method Detail

start

public void start(MBeanServiceContainer mBeanServiceContainer)

Specified by:

start in interface MBeanService<JmxManagedThreadPool>

stop

public void stop(MBeanServiceContainer mBeanServiceContainer)

Specified by:

stop in interface MBeanService<JmxManagedThreadPool>

getValue

public JmxManagedThreadPool getValue()

Specified by:

getValue in interface MBeanService<JmxManagedThreadPool>

setCorePoolSize

public void setCorePoolSize(int corePoolSize)

Specified by:

setCorePoolSize in interface JmxManagedThreadPoolMBean

setMaximumPoolSize

public void setMaximumPoolSize(int maximumPoolSize)

Specified by:

setMaximumPoolSize in interface JmxManagedThreadPoolMBean

getMaximumPoolSize

public int getMaximumPoolSize()

Specified by:

getMaximumPoolSize in interface JmxManagedThreadPoolMBean

setKeepAliveTime

public void setKeepAliveTime(long time,
                    TimeUnit unit)

purgeThreadPool

public void purgeThreadPool()

Specified by:

purgeThreadPool in interface JmxManagedThreadPoolMBean

getPoolSize

public int getPoolSize()

Specified by:

getPoolSize in interface JmxManagedThreadPoolMBean

getActiveCount

public int getActiveCount()

Specified by:

getActiveCount in interface JmxManagedThreadPoolMBean

getLargestPoolSize

public int getLargestPoolSize()

Specified by:

getLargestPoolSize in interface JmxManagedThreadPoolMBean

getTaskCount

public long getTaskCount()

Specified by:

getTaskCount in interface JmxManagedThreadPoolMBean

getCompletedTaskCount

public long getCompletedTaskCount()

Specified by:

getCompletedTaskCount in interface JmxManagedThreadPoolMBean

getQueueCount

public int getQueueCount()

Specified by:

getQueueCount in interface JmxManagedThreadPoolMBean

getThreadPoolExecutor

public ThreadPoolExecutor getThreadPoolExecutor()