Package org.apache.cassandra.metrics

Class ThreadPoolMetrics

java.lang.Object

org.apache.cassandra.metrics.ThreadPoolMetrics

public class ThreadPoolMetrics
extends Object

Metrics for ThreadPoolExecutor.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ACTIVE_TASKS
final com.codahale.metrics.Gauge<Integer>	activeTasks	Number of active tasks.
static final String	COMPLETED_TASKS
final com.codahale.metrics.Gauge<Long>	completedTasks	Number of completed tasks.
final com.codahale.metrics.Counter	currentBlocked	Number of tasks currently blocked, waiting to be accepted by the executor (because all threads are busy and the backing queue is full).
static final String	CURRENTLY_BLOCKED_TASKS
static final String	MAX_POOL_SIZE
static final String	MAX_TASKS_QUEUED
final com.codahale.metrics.Gauge<Integer>	maxPoolSize	Maximum number of threads before it will start queuing tasks
final com.codahale.metrics.Gauge<Integer>	maxTasksQueued	Maximum number of tasks queued before a task get blocked
static final String	OLDEST_TASK_QUEUE_TIME
final com.codahale.metrics.Gauge<Long>	oldestTaskQueueTime	For how long the oldest task in the queue was queued
final String	path
static final String	PENDING_TASKS
final com.codahale.metrics.Gauge<Integer>	pendingTasks	Number of tasks waiting to be executed.
final String	poolName
static final String	TOTAL_BLOCKED_TASKS
final com.codahale.metrics.Counter	totalBlocked	Number of tasks that had blocked before being accepted (or rejected).

Constructor Summary

Constructors

Constructor	Description
ThreadPoolMetrics(ResizableThreadPool executor, String path, String poolName)	Create metrics for given ThreadPoolExecutor.

Method Summary

Modifier and Type	Method	Description
ThreadPoolMetrics	register()
void	release()

Methods inherited from class java.lang.Object

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

Field Details

ACTIVE_TASKS

public static final String ACTIVE_TASKS

See Also:

• Constant Field Values

PENDING_TASKS

public static final String PENDING_TASKS

See Also:

• Constant Field Values

COMPLETED_TASKS

public static final String COMPLETED_TASKS

See Also:

• Constant Field Values

CURRENTLY_BLOCKED_TASKS

public static final String CURRENTLY_BLOCKED_TASKS

See Also:

• Constant Field Values

TOTAL_BLOCKED_TASKS

public static final String TOTAL_BLOCKED_TASKS

See Also:

• Constant Field Values

MAX_POOL_SIZE

public static final String MAX_POOL_SIZE

See Also:

• Constant Field Values

MAX_TASKS_QUEUED

public static final String MAX_TASKS_QUEUED

See Also:

• Constant Field Values

OLDEST_TASK_QUEUE_TIME

public static final String OLDEST_TASK_QUEUE_TIME

See Also:

• Constant Field Values

activeTasks

public final com.codahale.metrics.Gauge<Integer> activeTasks

Number of active tasks.

pendingTasks

public final com.codahale.metrics.Gauge<Integer> pendingTasks

Number of tasks waiting to be executed.

completedTasks

public final com.codahale.metrics.Gauge<Long> completedTasks

Number of completed tasks.

currentBlocked

public final com.codahale.metrics.Counter currentBlocked

Number of tasks currently blocked, waiting to be accepted by the executor (because all threads are busy and the backing queue is full).

totalBlocked

public final com.codahale.metrics.Counter totalBlocked

Number of tasks that had blocked before being accepted (or rejected).

maxPoolSize

public final com.codahale.metrics.Gauge<Integer> maxPoolSize

Maximum number of threads before it will start queuing tasks

oldestTaskQueueTime

public final com.codahale.metrics.Gauge<Long> oldestTaskQueueTime

For how long the oldest task in the queue was queued

maxTasksQueued

public final com.codahale.metrics.Gauge<Integer> maxTasksQueued

Maximum number of tasks queued before a task get blocked

path

public final String path

poolName

public final String poolName

Constructor Details

ThreadPoolMetrics

public ThreadPoolMetrics(ResizableThreadPool executor,
 String path,
 String poolName)

Create metrics for given ThreadPoolExecutor.

Parameters:

executor - Thread pool

path - Type of thread pool

poolName - Name of thread pool to identify metrics

Method Details

register

public ThreadPoolMetrics register()

release

public void release()