org.opendaylight.yangtools.util.concurrent

Class QueuedNotificationManager<L,N>

java.lang.Object

org.opendaylight.yangtools.util.concurrent.QueuedNotificationManager<L,N>

Type Parameters:

L - the listener type

N - the notification type

All Implemented Interfaces:

NotificationManager<L,N>

public class QueuedNotificationManager<L,N>
extends Object
implements NotificationManager<L,N>

This class manages queuing and dispatching notifications for multiple listeners concurrently. Notifications are queued on a per-listener basis and dispatched serially to each listener via an Executor.

This class optimizes its memory footprint by only allocating and maintaining a queue and executor task for a listener when there are pending notifications. On the first notification(s), a queue is created and a task is submitted to the executor to dispatch the queue to the associated listener. Any subsequent notifications that occur before all previous notifications have been dispatched are appended to the existing queue. When all notifications have been dispatched, the queue and task are discarded.

Author:

Thomas Pantelis

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	QueuedNotificationManager.Invoker<L,N> Interface implemented by clients that does the work of invoking listeners with notifications.

Constructor Summary

Constructors

Constructor and Description
QueuedNotificationManager(Executor executor, QueuedNotificationManager.Invoker<L,N> listenerInvoker, int maxQueueCapacity, String name) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
Executor	getExecutor() Returns the Executor to used for notification tasks.
List<ListenerNotificationQueueStats>	getListenerNotificationQueueStats() Returns ListenerNotificationQueueStats instances for each current listener notification task in progress.
int	getMaxQueueCapacity() Returns the maximum listener queue capacity.
void	submitNotification(L listener, N notification) Submits a notification to be queued and dispatched to the given listener.
void	submitNotifications(L listener, Iterable<N> notifications) Submits notifications to be queued and dispatched to the given listener.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueuedNotificationManager

public QueuedNotificationManager(Executor executor,
                         QueuedNotificationManager.Invoker<L,N> listenerInvoker,
                         int maxQueueCapacity,
                         String name)

Constructor.

Parameters:

executor - the Executor to use for notification tasks

listenerInvoker - the QueuedNotificationManager.Invoker to use for invoking listeners

maxQueueCapacity - the capacity of each listener queue

name - the name of this instance for logging info

Method Detail

submitNotification

public void submitNotification(L listener,
                      N notification)
                        throws RejectedExecutionException

Description copied from interface: NotificationManager

Submits a notification to be queued and dispatched to the given listener.

Note: This method may block if the listener queue is currently full.

Specified by:

submitNotification in interface NotificationManager<L,N>

Parameters:

listener - the listener to notify

notification - the notification to dispatch

Throws:

RejectedExecutionException - if the notification can't be queued for dispatching

submitNotifications

public void submitNotifications(L listener,
                       Iterable<N> notifications)
                         throws RejectedExecutionException

Description copied from interface: NotificationManager

Submits notifications to be queued and dispatched to the given listener.

Note: This method may block if the listener queue is currently full.

Specified by:

submitNotifications in interface NotificationManager<L,N>

Parameters:

listener - the listener to notify

notifications - the notifications to dispatch

Throws:

RejectedExecutionException - if a notification can't be queued for dispatching

getListenerNotificationQueueStats

public List<ListenerNotificationQueueStats> getListenerNotificationQueueStats()

Returns ListenerNotificationQueueStats instances for each current listener notification task in progress.

getMaxQueueCapacity

public int getMaxQueueCapacity()

Returns the maximum listener queue capacity.

getExecutor

public Executor getExecutor()

Returns the Executor to used for notification tasks.