Package org.opendaylight.yangtools.util.concurrent

Interface Summary

Interface	Description
NotificationManager<L,N>	Interface for a class that manages queuing and dispatching notifications for multiple listeners.
QueuedNotificationManager.Invoker<L,N>	Interface implemented by clients that does the work of invoking listeners with notifications.

Class Summary

Class	Description
AsyncNotifyingListenableFutureTask<V>	A FutureTask that also implements the ListenableFuture interface similar to guava's ListenableFutureTask.
AsyncNotifyingListeningExecutorService	An ListeningExecutorService implementation that also allows for an Executor to be specified on construction that is used to execute ListenableFuture callback Runnables, registered via Futures.addCallback(com.google.common.util.concurrent.ListenableFuture<V>, com.google.common.util.concurrent.FutureCallback<? super V>) or ListenableFuture.addListener(java.lang.Runnable, java.util.concurrent.Executor) directly, asynchronously when a task that is run on this executor completes.
CachedThreadPoolExecutor	A ThreadPoolExecutor with a specified bounded queue capacity that favors reusing previously constructed threads, when they are available, over creating new threads.
CountingRejectedExecutionHandler	A RejectedExecutionHandler that delegates to a backing RejectedExecutionHandler and counts the number of rejected tasks.
DeadlockDetectingListeningExecutorService	An implementation of ListeningExecutorService that attempts to detect deadlock scenarios that could occur if clients invoke the returned Future's get methods synchronously.
ExceptionMapper<X extends Exception>	Utility exception mapper which translates an Exception to a specified type of Exception.
FastThreadPoolExecutor	A ThreadPoolExecutor with a specified bounded queue capacity that favors creating new threads over queuing, as the former is faster.
ListenerNotificationQueueStats	Class used by the QueuedNotificationManager that contains a snapshot of notification queue statistics for a listener.
MappingCheckedFuture<V,X extends Exception>	An implementation of CheckedFuture that provides similar behavior for the get methods that the checkedGet methods provide.
QueuedNotificationManager<L,N>	This class manages queuing and dispatching notifications for multiple listeners concurrently.
ReflectiveExceptionMapper<X extends Exception>	Convenience ExceptionMapper which instantiates specified Exception using reflection.
SpecialExecutors	Factory methods for creating ExecutorService instances with specific configurations.
TrackingLinkedBlockingQueue<E>	A LinkedBlockingQueue that tracks the largest queue size for debugging.