Package 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, JmxManagedThreadPoolMBean, PlatformService<JmxManagedThreadPool>

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

Author:

Daniel Meyer

Field Summary

Fields

Modifier and Type	Field	Description
protected java.util.concurrent.BlockingQueue<java.lang.Runnable>	threadPoolQueue

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

threadPoolExecutor

Constructor Summary

Constructors

Constructor	Description
JmxManagedThreadPool(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue, java.util.concurrent.ThreadPoolExecutor executor)

Method Summary

Modifier and Type	Method	Description
int	getActiveCount()
long	getCompletedTaskCount()
int	getLargestPoolSize()
int	getMaximumPoolSize()
int	getPoolSize()
int	getQueueCount()
long	getTaskCount()
java.util.concurrent.ThreadPoolExecutor	getThreadPoolExecutor()
JmxManagedThreadPool	getValue()
void	purgeThreadPool()
void	setCorePoolSize(int corePoolSize)
void	setKeepAliveTime(long time, java.util.concurrent.TimeUnit unit)
void	setMaximumPoolSize(int maximumPoolSize)
void	start(PlatformServiceContainer mBeanServiceContainer)
void	stop(PlatformServiceContainer 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 java.util.concurrent.BlockingQueue<java.lang.Runnable> threadPoolQueue

Constructor Detail

JmxManagedThreadPool

public JmxManagedThreadPool(java.util.concurrent.BlockingQueue<java.lang.Runnable> queue,
                            java.util.concurrent.ThreadPoolExecutor executor)

Method Detail

start

public void start(PlatformServiceContainer mBeanServiceContainer)

Specified by:

start in interface PlatformService<JmxManagedThreadPool>

stop

public void stop(PlatformServiceContainer mBeanServiceContainer)

Specified by:

stop in interface PlatformService<JmxManagedThreadPool>

getValue

public JmxManagedThreadPool getValue()

Specified by:

getValue in interface PlatformService<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,
                             java.util.concurrent.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 java.util.concurrent.ThreadPoolExecutor getThreadPoolExecutor()