com.netflix.hystrix

Class HystrixThreadPoolMetrics

java.lang.Object

com.netflix.hystrix.HystrixMetrics

com.netflix.hystrix.HystrixThreadPoolMetrics

public class HystrixThreadPoolMetrics
extends HystrixMetrics

Used by HystrixThreadPool to record metrics.

Field Summary

Fields inherited from class com.netflix.hystrix.HystrixMetrics

counter

Method Summary

Methods

Modifier and Type	Method and Description
long	getCumulativeCountThreadsExecuted() Cumulative count of number of threads executed since the start of the application.
Number	getCurrentActiveCount() Value from ThreadPoolExecutor.getActiveCount()
Number	getCurrentCompletedTaskCount() Value from ThreadPoolExecutor.getCompletedTaskCount()
Number	getCurrentCorePoolSize() Value from ThreadPoolExecutor.getCorePoolSize()
Number	getCurrentLargestPoolSize() Value from ThreadPoolExecutor.getLargestPoolSize()
Number	getCurrentMaximumPoolSize() Value from ThreadPoolExecutor.getMaximumPoolSize()
Number	getCurrentPoolSize() Value from ThreadPoolExecutor.getPoolSize()
Number	getCurrentQueueSize() Current size of BlockingQueue used by the thread-pool
Number	getCurrentTaskCount() Value from ThreadPoolExecutor.getTaskCount()
static HystrixThreadPoolMetrics	getInstance(HystrixThreadPoolKey key) Get the HystrixThreadPoolMetrics instance for a given HystrixThreadPoolKey or null if one does not exist.
static HystrixThreadPoolMetrics	getInstance(HystrixThreadPoolKey key, ThreadPoolExecutor threadPool, HystrixThreadPoolProperties properties) Get or create the HystrixThreadPoolMetrics instance for a given HystrixThreadPoolKey.
static Collection<HystrixThreadPoolMetrics>	getInstances() All registered instances of HystrixThreadPoolMetrics
HystrixThreadPoolProperties	getProperties() HystrixThreadPoolProperties of the HystrixThreadPool these metrics represent.
long	getRollingCountThreadsExecuted() Rolling count of number of threads executed during rolling statistical window.
long	getRollingMaxActiveThreads() Rolling max number of active threads during rolling statistical window.
ThreadPoolExecutor	getThreadPool() ThreadPoolExecutor this executor represents.
HystrixThreadPoolKey	getThreadPoolKey() HystrixThreadPoolKey these metrics represent.
void	markThreadCompletion() Invoked each time a thread completes.
void	markThreadExecution() Invoked each time a thread is executed.
void	markThreadRejection() Invoked each time a command is rejected from the thread-pool

Methods inherited from class com.netflix.hystrix.HystrixMetrics

getCumulativeCount, getRollingCount

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static HystrixThreadPoolMetrics getInstance(HystrixThreadPoolKey key,
                                   ThreadPoolExecutor threadPool,
                                   HystrixThreadPoolProperties properties)

Get or create the HystrixThreadPoolMetrics instance for a given HystrixThreadPoolKey.

This is thread-safe and ensures only 1 HystrixThreadPoolMetrics per HystrixThreadPoolKey.

Parameters:

key - HystrixThreadPoolKey of HystrixThreadPool instance requesting the HystrixThreadPoolMetrics

threadPool - Pass-thru of ThreadPoolExecutor to HystrixThreadPoolMetrics instance on first time when constructed

properties - Pass-thru to HystrixThreadPoolMetrics instance on first time when constructed

Returns:

HystrixThreadPoolMetrics

getInstance

public static HystrixThreadPoolMetrics getInstance(HystrixThreadPoolKey key)

Get the HystrixThreadPoolMetrics instance for a given HystrixThreadPoolKey or null if one does not exist.

Parameters:

key - HystrixThreadPoolKey of HystrixThreadPool instance requesting the HystrixThreadPoolMetrics

Returns:

HystrixThreadPoolMetrics

getInstances

public static Collection<HystrixThreadPoolMetrics> getInstances()

All registered instances of HystrixThreadPoolMetrics

Returns:

Collection<HystrixThreadPoolMetrics>

getThreadPool

public ThreadPoolExecutor getThreadPool()

ThreadPoolExecutor this executor represents.

Returns:

ThreadPoolExecutor

getThreadPoolKey

public HystrixThreadPoolKey getThreadPoolKey()

HystrixThreadPoolKey these metrics represent.

Returns:

HystrixThreadPoolKey

getProperties

public HystrixThreadPoolProperties getProperties()

HystrixThreadPoolProperties of the HystrixThreadPool these metrics represent.

Returns:

HystrixThreadPoolProperties

getCurrentActiveCount

public Number getCurrentActiveCount()

Value from ThreadPoolExecutor.getActiveCount()

Returns:

Number

getCurrentCompletedTaskCount

public Number getCurrentCompletedTaskCount()

Value from ThreadPoolExecutor.getCompletedTaskCount()

Returns:

Number

getCurrentCorePoolSize

public Number getCurrentCorePoolSize()

Value from ThreadPoolExecutor.getCorePoolSize()

Returns:

Number

getCurrentLargestPoolSize

public Number getCurrentLargestPoolSize()

Value from ThreadPoolExecutor.getLargestPoolSize()

Returns:

Number

getCurrentMaximumPoolSize

public Number getCurrentMaximumPoolSize()

Value from ThreadPoolExecutor.getMaximumPoolSize()

Returns:

Number

getCurrentPoolSize

public Number getCurrentPoolSize()

Value from ThreadPoolExecutor.getPoolSize()

Returns:

Number

getCurrentTaskCount

public Number getCurrentTaskCount()

Value from ThreadPoolExecutor.getTaskCount()

Returns:

Number

getCurrentQueueSize

public Number getCurrentQueueSize()

Current size of BlockingQueue used by the thread-pool

Returns:

Number

markThreadExecution

public void markThreadExecution()

Invoked each time a thread is executed.

getRollingCountThreadsExecuted

public long getRollingCountThreadsExecuted()

Rolling count of number of threads executed during rolling statistical window.

The rolling window is defined by HystrixThreadPoolProperties.metricsRollingStatisticalWindowInMilliseconds().

Returns:

rolling count of threads executed

getCumulativeCountThreadsExecuted

public long getCumulativeCountThreadsExecuted()

Cumulative count of number of threads executed since the start of the application.

Returns:

cumulative count of threads executed

markThreadCompletion

public void markThreadCompletion()

Invoked each time a thread completes.

getRollingMaxActiveThreads

public long getRollingMaxActiveThreads()

Rolling max number of active threads during rolling statistical window.

The rolling window is defined by HystrixThreadPoolProperties.metricsRollingStatisticalWindowInMilliseconds().

Returns:

rolling max active threads

markThreadRejection

public void markThreadRejection()

Invoked each time a command is rejected from the thread-pool