com.bigdata.util.concurrent

Class QueueSizeMovingAverageTask

java.lang.Object

com.bigdata.util.concurrent.MovingAverageTask

com.bigdata.util.concurrent.QueueSizeMovingAverageTask

All Implemented Interfaces:

Runnable

public class QueueSizeMovingAverageTask
extends MovingAverageTask
implements Runnable

Class tracks the moving average of the queue size.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.util.concurrent.MovingAverageTask

average, DEFAULT_WEIGHT, log, name, nsamples, sampleTask, w

Constructor Summary

Constructors

Constructor and Description
QueueSizeMovingAverageTask(String name, BlockingQueue<?> queue)
QueueSizeMovingAverageTask(String name, BlockingQueue<?> queue, double w) Core impl.

Method Summary

Methods

Modifier and Type	Method and Description
double	getAverageQueueSize() The size of the queue (moving average).

Methods inherited from class com.bigdata.util.concurrent.MovingAverageTask

getMovingAverage, getMovingAverage, getSampleCount, getWeight, run

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Constructor Detail

QueueSizeMovingAverageTask

public QueueSizeMovingAverageTask(String name,
                          BlockingQueue<?> queue)

Parameters:

name - The label for the service.

queue - The queue to be monitored.

QueueSizeMovingAverageTask

public QueueSizeMovingAverageTask(String name,
                          BlockingQueue<?> queue,
                          double w)

Core impl.

Parameters:

name - The label for the service.

queue - The queue to be monitored.

w - The weight to be used by MovingAverageTask.getMovingAverage(double, double, double)

Method Detail

getAverageQueueSize

public double getAverageQueueSize()

The size of the queue (moving average).

See Also:

IQueueCounters.AverageQueueSize