com.bigdata.util.concurrent

Interface IQueueCounters.IThreadPoolExecutorTaskCounters

All Superinterfaces:

ICounterHierarchy, IQueueCounters

All Known Subinterfaces:

IQueueCounters.IWriteServiceExecutorCounters

Enclosing interface:

IQueueCounters

public static interface IQueueCounters.IThreadPoolExecutorTaskCounters
extends IQueueCounters

Additional counters available for any ThreadPoolExecutor which is processing AbstractTasks.

Note: The ConcurrencyManager and AbstractTask work together to maintain the per-service TaskCounterss on which these additional counters are based.

Version:

$Id$

Author:

Bryan Thompson

Nested Class Summary

Nested classes/interfaces inherited from interface com.bigdata.util.concurrent.IQueueCounters

IQueueCounters.ITaskCounters, IQueueCounters.IThreadPoolExecutorCounters, IQueueCounters.IThreadPoolExecutorTaskCounters, IQueueCounters.IWriteServiceExecutorCounters

Field Summary

Fields

Modifier and Type	Field and Description
static String	AverageArrivalRate The average arrival rate in tasks per millisecond (1/average-inter-arrival-time).
static String	AverageCheckpointTime Moving average in milliseconds of the time that a task is checkpointing the indices on which it has written (this is already reported as part of the AverageServiceTime but is broken out here as a detail).
static String	AverageQueueWaitingTime Moving average in milliseconds of the time a task waits on a queue pending execution.
static String	AverageQueuingTime Moving average in milliseconds of the time between the submission of a task and its completion including any time spent waiting for resource locks, commit processing and any time spent servicing that task.
static String	AverageServiceRate The average service rate in tasks per millisecond (1/average-service-time).
static String	AverageServiceTime Moving average in milliseconds of the time that a task is being serviced by a worker thread (elapsed clock time from when the task was assigned to the thread until the task completes its work).
static String	TaskFailCount Count of all tasks which failed during execution.
static String	TaskSubmitCount Count of all tasks submitted to the service.
static String	TaskSuccessCount Count of all tasks which were successfully executed.

Fields inherited from interface com.bigdata.util.concurrent.IQueueCounters

AverageQueueSize

Fields inherited from interface com.bigdata.counters.ICounterHierarchy

CPU, Info, LogicalDisk, Memory, Memory_GarbageCollectors, Memory_Memory_Pools, PhysicalDisk, ps

Field Detail

TaskSubmitCount

static final String TaskSubmitCount

Count of all tasks submitted to the service.

See Also:

IQueueCounters.ITaskCounters.TaskSubmitCount, Constant Field Values

TaskFailCount

static final String TaskFailCount

Count of all tasks which failed during execution.

See Also:

IQueueCounters.ITaskCounters.TaskFailCount, Constant Field Values

TaskSuccessCount

static final String TaskSuccessCount

Count of all tasks which were successfully executed.

See Also:

IQueueCounters.ITaskCounters.TaskSuccessCount, Constant Field Values

AverageArrivalRate

static final String AverageArrivalRate

The average arrival rate in tasks per millisecond (1/average-inter-arrival-time).

See Also:

Constant Field Values

AverageServiceRate

static final String AverageServiceRate

The average service rate in tasks per millisecond (1/average-service-time).

See Also:

Constant Field Values

AverageQueueWaitingTime

static final String AverageQueueWaitingTime

Moving average in milliseconds of the time a task waits on a queue pending execution.

See Also:

IQueueCounters.ITaskCounters.QueueWaitingTime, Constant Field Values

AverageServiceTime

static final String AverageServiceTime

Moving average in milliseconds of the time that a task is being serviced by a worker thread (elapsed clock time from when the task was assigned to the thread until the task completes its work).

Note: For tasks which acquire resource lock(s), this does NOT include the time waiting to acquire the resource lock(s).

Note: The average service rate is the inverse of the AverageServiceTime.

See Also:

IQueueCounters.ITaskCounters.ServiceTime, Constant Field Values

AverageCheckpointTime

static final String AverageCheckpointTime

Moving average in milliseconds of the time that a task is checkpointing the indices on which it has written (this is already reported as part of the AverageServiceTime but is broken out here as a detail). An index checkpoint operation consists of flushing all dirty pages to the backing store and then writing a new Checkpoint record on the backing store. This operation is an after action of a successful write task.

See Also:

IQueueCounters.ITaskCounters.CheckpointTime, Constant Field Values

AverageQueuingTime

static final String AverageQueuingTime

Moving average in milliseconds of the time between the submission of a task and its completion including any time spent waiting for resource locks, commit processing and any time spent servicing that task.

See Also:

IQueueCounters.ITaskCounters.QueuingTime, Constant Field Values