Package com.bigdata.util.concurrent

Utility classes related to java.util.concurrent.

See: Description

Interface Summary

Interface	Description
Computable<A,V>	Something which computes one value from another.
IHaltable<V>	Interface extends Future and provides an interface for managing the termination of a process from within that process.
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

Class	Description
AbstractHaltableProcess	Abstract base class for tasks whose processing may be halted asynchronously.
CanonicalFactory<KEY,VAL,STATE>	A pattern for a canonicalizing factory based on a map with weak values.
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.
Haltable<V>	Abstract base class for tasks whose processing may be halted asynchronously.
Latch	A synchronization aid that allows one or more threads to await a counter becoming zero.
LatchedExecutor	A fly weight helper class that runs tasks either sequentially or with limited parallelism against some thread pool.
MappedTaskExecutor	Deprecated by LatchedExecutorService which has higher throughput and plays more nicely with the Executor paradigm.
Memoizer<A,V>	Pattern using a FutureTask to force synchronization only on tasks waiting for the same computation.
MonitoredFutureTask<T>	Helper task for monitoring the results of otherwise unwatched tasks.
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.
TestAll	Aggregates test suites in increasing dependency order.
TestHaltable	Test suite for Haltable.
TestLatch	Unit tests for Latch.
ThreadGuard	Pattern used to guard critical regions that await Conditions when a concurrent event may cause the Condition to become unsatisfiable.
ThreadGuard.Guard
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

Exception	Description
ExecutionExceptions	Class enumerates all exceptions thrown for a set of tasks.

Package com.bigdata.util.concurrent Description

Utility classes related to java.util.concurrent.