com.bigdata.util.concurrent

Class ThreadPoolExecutorBaseStatisticsTask

java.lang.Object

com.bigdata.util.concurrent.ThreadPoolExecutorBaseStatisticsTask

All Implemented Interfaces:

Runnable

public class ThreadPoolExecutorBaseStatisticsTask
extends Object
implements Runnable

Class tracks a variety of information about a ThreadPoolExecutor including the moving average of its queue length, queue size, average active count, etc.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected ThreadPoolExecutor	service The executor service that is being monitored.
protected long	startNanos The time when we started to collect data about the service (set by the ctor).
protected double	w The weight used to compute the moving average.

Constructor Summary

Constructors

Constructor and Description
ThreadPoolExecutorBaseStatisticsTask(ThreadPoolExecutor service)
ThreadPoolExecutorBaseStatisticsTask(ThreadPoolExecutor service, double w) Core impl.

Method Summary

Methods

Modifier and Type	Method and Description
CounterSet	getCounters() Return the moving averages and various other counters sampled and reported by this class.
void	run() This should be invoked once per second to sample various counters in order to turn their values into moving averages.

Methods inherited from class java.lang.Object

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

Field Detail

service

protected final ThreadPoolExecutor service

The executor service that is being monitored.

startNanos

protected final long startNanos

The time when we started to collect data about the service (set by the ctor).

w

protected final double w

The weight used to compute the moving average.

Constructor Detail

ThreadPoolExecutorBaseStatisticsTask

public ThreadPoolExecutorBaseStatisticsTask(ThreadPoolExecutor service)

Parameters:

service - The service to be monitored.

ThreadPoolExecutorBaseStatisticsTask

public ThreadPoolExecutorBaseStatisticsTask(ThreadPoolExecutor service,
                                    double w)

Core impl.

Parameters:

service - The service to be monitored.

w - The weight to be used by the MovingAverageTasks.

Method Detail

run

public void run()

This should be invoked once per second to sample various counters in order to turn their values into moving averages.

Note: don't throw anything from here or it will cause the scheduled task executing this to no longer be run!

Specified by:

run in interface Runnable

getCounters

public CounterSet getCounters()

Return the moving averages and various other counters sampled and reported by this class.