co.paralleluniverse.common.monitoring

Class JMXForkJoinPoolMonitor

java.lang.Object

co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor

co.paralleluniverse.common.monitoring.JMXForkJoinPoolMonitor

All Implemented Interfaces:

ForkJoinPoolMXBean

public class JMXForkJoinPoolMonitor
extends ForkJoinPoolMonitor
implements ForkJoinPoolMXBean

Nested Class Summary

Nested classes/interfaces inherited from class co.paralleluniverse.common.monitoring.ForkJoinPoolMonitor

ForkJoinPoolMonitor.Status

Constructor Summary

Constructors

Constructor and Description
JMXForkJoinPoolMonitor(java.lang.String name, java.util.concurrent.ForkJoinPool fjPool)

Method Summary

Modifier and Type	Method and Description
protected java.util.concurrent.ForkJoinPool	fjPool()
int	getActiveThreadCount()
boolean	getAsyncMode()
ForkJoinInfo	getInfo()
long[]	getLatency()
java.lang.String	getMbeanName()
int	getParallelism()
int	getPoolSize()
int	getQueuedSubmissionCount()
long	getQueuedTaskCount()
int	getRunningThreadCount()
ForkJoinPoolMonitor.Status	getStatus()
long	getStealCount()
boolean	isRegistered()
protected void	registerMBean()
void	shutdown()
void	shutdownNow()
void	unregister()

Methods inherited from class java.lang.Object

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

Constructor Detail

JMXForkJoinPoolMonitor

public JMXForkJoinPoolMonitor(java.lang.String name,
                              java.util.concurrent.ForkJoinPool fjPool)

Method Detail

registerMBean

protected void registerMBean()

unregister

public void unregister()

Overrides:

unregister in class ForkJoinPoolMonitor

getMbeanName

public java.lang.String getMbeanName()

isRegistered

public boolean isRegistered()

fjPool

protected java.util.concurrent.ForkJoinPool fjPool()

Overrides:

fjPool in class ForkJoinPoolMonitor

getStatus

public ForkJoinPoolMonitor.Status getStatus()

Specified by:

getStatus in interface ForkJoinPoolMXBean

getAsyncMode

public boolean getAsyncMode()

Specified by:

getAsyncMode in interface ForkJoinPoolMXBean

getParallelism

public int getParallelism()

Specified by:

getParallelism in interface ForkJoinPoolMXBean

getPoolSize

public int getPoolSize()

Specified by:

getPoolSize in interface ForkJoinPoolMXBean

getActiveThreadCount

public int getActiveThreadCount()

Specified by:

getActiveThreadCount in interface ForkJoinPoolMXBean

getRunningThreadCount

public int getRunningThreadCount()

Specified by:

getRunningThreadCount in interface ForkJoinPoolMXBean

getQueuedSubmissionCount

public int getQueuedSubmissionCount()

Specified by:

getQueuedSubmissionCount in interface ForkJoinPoolMXBean

getQueuedTaskCount

public long getQueuedTaskCount()

Specified by:

getQueuedTaskCount in interface ForkJoinPoolMXBean

getStealCount

public long getStealCount()

Specified by:

getStealCount in interface ForkJoinPoolMXBean

getLatency

public long[] getLatency()

Specified by:

getLatency in interface ForkJoinPoolMXBean

getInfo

public ForkJoinInfo getInfo()

Specified by:

getInfo in interface ForkJoinPoolMXBean

shutdown

public void shutdown()

Specified by:

shutdown in interface ForkJoinPoolMXBean

shutdownNow

public void shutdownNow()

Specified by:

shutdownNow in interface ForkJoinPoolMXBean