Package org.apache.river.thread

These are utility classes and interfaces for helping with tasks done in multiple threads.

See: Description

Interface Summary

Interface	Description
Executor	Executor is an abstraction for a thread factory or thread pool for executing actions asynchronously.
ExtensibleExecutorService.RunnableFutureFactory	Factory for creating custom RunnableFuture implementations.
FutureObserver<T>
FutureObserver.ObservableFuture<T>
InterruptedStatusThread.Interruptable	A Runnable task can implement this to be interrupted if something special needs to be done to cause the Runnable to notice it's been interrupted.
TaskManager.Task	The interface that tasks must implement

Class Summary

Class	Description
DependencyLinker
ExtensibleExecutorService	AbstractExecutorService introduced two protected methods in Java 1.6 to allow an ExecutorService to use customised RunnableFuture implementations other than the default FutureTask.
GetThreadPoolAction	Provides security-checked access to internal thread pools as a java.security.PrivilegedAction, to be used conveniently with an AccessController.doPrivileged or Security.doPrivileged.
InProgress	This class provides a blocking mechanism that will not proceed while some operation bounded by this object is in progress.
InterruptedStatusThread	Common Thread subclass to handle potential loss of interrupted status.
NamedThreadFactory	A utility to help readability of pool threads
NewThreadAction	A PrivilegedAction for creating a new thread conveniently with an AccessController.doPrivileged or Security.doPrivileged.
ObservableFutureTask<T>
ReadersWriter	An Object to control the concurrent state.
ReadyState	Utility class used to prevent access to a service before it has completed its initialization or after it starts to shutdown.
RetryTask<V>
StreamPlugThread	StreamPlugThread is a utility class that "plugs" two streams, one input stream and one output stream, together by creating a thread that repeatedly reads any data available from the input stream and writes it to the output stream.
SynchronousExecutors	The intent of this Executor is to share a single thread pool among tasks with dependencies that prevent them running concurrently.
TaskManager	Deprecated will be removed from a future release soon.
ThreadPoolPermission	Permission to use internal thread pools (see GetThreadPoolAction).
WakeupManager	A Queue of timed tasks.
WakeupManager.ThreadDesc	Description of a future thread.
WakeupManager.Ticket	A ticket that can be used for cancelling a future task.

Exception Summary

Exception	Description
ReadersWriter.ConcurrentLockException	InterruptedException transformed to a runtime exception.

Package org.apache.river.thread Description

These are utility classes and interfaces for helping with tasks done in multiple threads. Some utilities (such as InProgress) provide synchronization mechanisms. Others, such as TaskManager, provide utilities for managing the creation of multiple threads to do independent tasks.