Package com.bigdata.util.concurrent

Utility classes related to java.util.concurrent.

See:
Description

Interface Summary

IQueueCounters	Interface defines and documents the names and meanings of counters pertaining to blocking queues (of tasks) and services executing tasks and includes counters pertaining to the service executing ITx.UNISOLATED tasks - the WriteExecutorService.
IQueueCounters.ITaskCounters	Counters defined by TaskCounters.
IQueueCounters.IThreadPoolExecutorCounters	Additional counters available for any ThreadPoolExecutor.
IQueueCounters.IThreadPoolExecutorTaskCounters	Additional counters available for any ThreadPoolExecutor which is processing AbstractTasks.
IQueueCounters.IWriteServiceExecutorCounters	Additional counters available for the WriteServiceExecutor.

Class Summary

AbstractHaltableProcess	Abstract base class for tasks whose processing may be halted asynchronously.
DaemonThreadFactory	A thread factory that configures the thread as a daemon thread.
DeltaMovingAverageTask	Moving average based on the change in some sampled value.
ExecutionHelper<T>	Helper class for managing the execution of a set of Callable tasks on an ExecutorService.
Latch	A synchronization aid that allows one or more threads to await a counter becoming zero.
MappedTaskExecutor	A fly weight helper class that runs tasks either sequentially or with limited parallelism against some thread pool.
MovingAverageTask	Class tracks a the moving average of some sampled datum.
QueueSizeMovingAverageTask	Class tracks the moving average of the queue size.
ShutdownHelper	Helper class for normal shutdown of an ExecutorService.
TaskCounters	Class captures various data about the execution of AbstractTasks.
ThreadPoolExecutorBaseStatisticsTask	Class tracks a variety of information about a ThreadPoolExecutor including the moving average of its queue length, queue size, average active count, etc.
ThreadPoolExecutorStatisticsTask	Class tracks a variety of information about a ThreadPoolExecutor including the moving average of its queue length, queuing times, etc.
WriteTaskCounters	Extended for the WriteExecutorService.

Exception Summary

ExecutionExceptions

Class enumerates all exceptions thrown for a set of tasks.

Package com.bigdata.util.concurrent Description

Utility classes related to java.util.concurrent.