com.bigdata.util.concurrent

Class TaskCounters

java.lang.Object

com.bigdata.util.concurrent.TaskCounters

Direct Known Subclasses:

IndexSyncRPCCounters, WriteTaskCounters

public class TaskCounters
extends Object

Class captures various data about the execution of AbstractTasks. These data are collected by the ConcurrencyManager in groups the different services on which the tasks are run.

Note: The field names here are consistent with those in the ThreadPoolExecutorStatisticsTask.

Note: The various counters are AtomicLongs since we need them to be thread-safe. (counter++ and counter+=foo are NOT guaranteed to be thread-safe for simple fields or even volatile fields).

See Also:

ThreadPoolExecutorStatisticsTask

Field Summary

Fields

Modifier and Type	Field and Description
AtomicLong	checkpointNanoTime Cumulative elapsed time in nanoseconds consumed by write tasks while checkpointing their indices.
AtomicLong	interArrivalNanoTime Cumulative elapsed time in nanoseconds between the arrival of tasks.
AtomicLong	lastArrivalNanoTime The timestamp in nanoseconds when the last task arrived.
AtomicLong	queueWaitingNanoTime Cumulative elapsed time in nanoseconds waiting on the queue pending service.
AtomicLong	queuingNanoTime Cumulative elapsed time in nanoseconds consumed by tasks from when they are submitted until they are complete.
AtomicLong	serviceNanoTime Cumulative elapsed time in nanoseconds consumed by tasks while assigned to a worker thread.
AtomicLong	taskCompleteCount #of tasks that have been completed.
AtomicLong	taskFailCount #of tasks that failed.
AtomicLong	taskSubmitCount #of tasks that have been submitted.
AtomicLong	taskSuccessCount #of tasks that succeeded.

Constructor Summary

Constructors

Constructor and Description
TaskCounters() Ctor

Method Summary

Methods

Modifier and Type	Method and Description
CounterSet	getCounters() Note: The elapsed time counters (queueWaitingNanoTime, serviceNanoTime, and queuingNanoTime) are reported as cumulative milliseconds by this method.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

taskSubmitCount

public final AtomicLong taskSubmitCount

#of tasks that have been submitted.

taskCompleteCount

public final AtomicLong taskCompleteCount

#of tasks that have been completed.

taskFailCount

public final AtomicLong taskFailCount

#of tasks that failed.

taskSuccessCount

public final AtomicLong taskSuccessCount

#of tasks that succeeded.

lastArrivalNanoTime

public final AtomicLong lastArrivalNanoTime

The timestamp in nanoseconds when the last task arrived.

interArrivalNanoTime

public final AtomicLong interArrivalNanoTime

Cumulative elapsed time in nanoseconds between the arrival of tasks.

queueWaitingNanoTime

public final AtomicLong queueWaitingNanoTime

Cumulative elapsed time in nanoseconds waiting on the queue pending service.

serviceNanoTime

public final AtomicLong serviceNanoTime

Cumulative elapsed time in nanoseconds consumed by tasks while assigned to a worker thread.

Note: Since this is aggregated over concurrent tasks the reported elapsed time MAY exceed the actual elapsed time during which those tasks were executed.

Note: Service time on the client includes queuing time on the service and the checkpoint time (for write tasks).

checkpointNanoTime

public final AtomicLong checkpointNanoTime

Cumulative elapsed time in nanoseconds consumed by write tasks while checkpointing their indices.

Note: Since this is aggregated over concurrent tasks the reported elapsed time MAY exceed the actual elapsed time during which those tasks were executed.

Note: This time is already reported by the serviceNanoTime but is broken out here for additional detail. Checkpoint time can be most of the service time for a task since indices buffer writes and but are required to flush those writes to the backing during during a checkpoint.

queuingNanoTime

public final AtomicLong queuingNanoTime

Cumulative elapsed time in nanoseconds consumed by tasks from when they are submitted until they are complete.

Note: Queuing time on the client includes queuing time on the service.

Constructor Detail

TaskCounters

public TaskCounters()

Ctor

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getCounters

public CounterSet getCounters()

Note: The elapsed time counters (queueWaitingNanoTime, serviceNanoTime, and queuingNanoTime) are reported as cumulative milliseconds by this method. These data are turned into moving averages by the ThreadPoolExecutorStatisticsTask.