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.BatchedInvoker<L,N>
static interface	QueuedNotificationManager.Invoker<L,N> Deprecated. Use QueuedNotificationManager.BatchedInvoker instead.

Constructor Summary

Constructors

Constructor and Description
QueuedNotificationManager(@NonNull Executor executor, @NonNull QueuedNotificationManager.Invoker<L,N> listenerInvoker, int maxQueueCapacity, @NonNull String name) Deprecated. Use create(Executor, BatchedInvoker, int, String) instead.

Method Summary

Modifier and Type	Method and Description
static <L,N> QueuedNotificationManager<L,N>	create(@NonNull Executor executor, @NonNull QueuedNotificationManager.BatchedInvoker<L,N> listenerInvoker, int maxQueueCapacity, @NonNull String name) Create a new notification manager.
@NonNull 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

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

Deprecated. Use create(Executor, BatchedInvoker, int, String) instead.

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

create

public static <L,N> QueuedNotificationManager<L,N> create(@NonNull Executor executor,
                                                          @NonNull QueuedNotificationManager.BatchedInvoker<L,N> listenerInvoker,
                                                          int maxQueueCapacity,
                                                          @NonNull String name)

Create a new notification manager.

Parameters:

executor - the Executor to use for notification tasks

listenerInvoker - the QueuedNotificationManager.BatchedInvoker to use for invoking listeners

maxQueueCapacity - the capacity of each listener queue

name - the name of this instance for logging info

getMaxQueueCapacity

public int getMaxQueueCapacity()

Returns the maximum listener queue capacity.

getExecutor

public @NonNull Executor getExecutor()

Returns the Executor to used for notification tasks.

submitNotification

public void submitNotification(L listener,
                               N notification)

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

submitNotifications

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

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

getListenerNotificationQueueStats

public List<ListenerNotificationQueueStats> getListenerNotificationQueueStats()

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