Package de.aristaflow.adept2.util.threading

Interface Summary

Interface	Description
ConsumingRunnable<T,E extends Throwable>	A runnable consuming an object of type T or an exception of type E.
ProducingRunnable<T,E extends Exception>	A runnable producing an object of type T and throwing an exception of type E.
ThrowableCreatingCallable<V,T extends Throwable>	This interface encapsulates the creation of a new throwable based on an occurred throwable.

Class Summary

Class	Description
AbstractPipeliningExecutor<O,P>	Deprecated. Use AbstractPipeliningExecutor instead.
Adept2ThreadFactory	The default thread factory overwritten to name the threads.
AFThreadPoolExecutor	This thread pool executor enhances a normal thread pool by: prepending the state of a thread to the thread name, logging exceptions (and results) of futures where no one has been interested in and logging statistics. Thread names will be prefixed as following: NEW: Used for newly created threads. ACT: Used for active threads that are currently executing tasks. IDL: Used for idle threads, i.e. threads that may be reused. Every task is wrapped by a LoggingFuture.
CachedThreadPoolExecutor	A ThreadPoolExecutor which comes in two flavours: Creates new threads to run a new task, if the amount of threads is less than the corePoolSize.
CleanupCallable<V>	A cleanup callable executes a callable and afterwards a special cleanup consuming runnable finally after the first callable.
CleanupRunnable	A cleanup runnable executes a runnable (or several ones) and afterwards a special cleanup runnable finally after the first runnable.
CurrentThreadPoolExecutor	A thread pool for executing the tasks by the submitting thread.
Delayer<T>	A delayer provides the means to delay a call based on the amount of tries a provided element has experienced.
ExceptionConvertingCallable<V,E extends Exception>	This class provides the means to call a method and replace an occurred exception by a different one.
ExceptionLoggingCallable<V>	A callable catching exceptions and virtual machine errors and optionally rethrowing them.
ExceptionLoggingRunnable	A runnable catching runtime exceptions and virtual machine errors and optionally rethrowing them.
ExecutorTools	Executor-related utility methods.
LimitedPipelineExecutor<O>	Deprecated. Use LimitedPipelineExecutor instead.
LoggingFuture<V>	A future that wraps another future and logs all occurred exceptions and the result for information purpose if no one was interested in it.
LoggingFuture.IgnoredResultLogger	This clean-up task logs the result of a future which no one retrieved.
LoggingScheduledFuture<V>	A scheduled future that wraps another future and logs all occurred exceptions and the result for information purpose if no one was interested in it.
LoggingScheduledThreadPoolExecutor	This class creates logging futures when scheduling.
PipelineFlushRunnable<P>	Deprecated. Use ObjectSpecificFlushCallable instead.
PipelineRunnable<P>	Deprecated. Use PipelineRunnable instead.
ResultExchange<T>	This class provides the means to exchange a result between different threads.
ThreadTools	Thread-related tool methods.
UnlimitedPipelineExecutor<O>	Deprecated. Use UnlimitedPipelineExecutor instead.